org.springframework.data.gemfire.wan
Class GatewaySenderFactoryBean

java.lang.Object
  extended by org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>
      extended by org.springframework.data.gemfire.wan.GatewaySenderFactoryBean
All Implemented Interfaces:
Aware, BeanNameAware, DisposableBean, FactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>, InitializingBean

public class GatewaySenderFactoryBean
extends AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>

FactoryBean for creating a GemFire GatewaySender.


Field Summary
 
Fields inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean
cache, factory, log
 
Constructor Summary
GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)
           
 
Method Summary
protected  void doInit()
           
 com.gemstone.gemfire.cache.wan.GatewaySender getObject()
           
 Class<?> getObjectType()
           
 void setAlertThreshold(Integer alertThreshold)
           
 void setBatchSize(Integer batchSize)
           
 void setBatchTimeInterval(Integer batchTimeInterval)
           
 void setDiskStoreRef(String diskStoreRef)
           
 void setDiskSynchronous(Boolean diskSynchronous)
           
 void setDispatcherThreads(Integer dispatcherThreads)
           
 void setEnableBatchConflation(Boolean enableBatchConflation)
           
 void setEventFilters(List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> gatewayEventFilters)
           
 void setManualStart(Boolean manualStart)
           
 void setMaximumQueueMemory(Integer maximumQueueMemory)
           
 void setOrderPolicy(String orderPolicy)
           
 void setParallel(Boolean parallel)
           
 void setPersistent(Boolean persistent)
           
 void setRemoteDistributedSystemId(int remoteDistributedSystemId)
           
 void setSocketBufferSize(Integer socketBufferSize)
           
 void setSocketReadTimeout(Integer socketReadTimeout)
           
 void setTransportFilters(List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> gatewayTransportFilters)
           
 
Methods inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean
afterPropertiesSet, destroy, getName, isSingleton, setBeanName, setFactory, setName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GatewaySenderFactoryBean

public GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)
Parameters:
cache - the Gemfire cache
Method Detail

getObject

public com.gemstone.gemfire.cache.wan.GatewaySender getObject()
                                                       throws Exception
Specified by:
getObject in interface FactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>
Specified by:
getObject in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>
Throws:
Exception

getObjectType

public Class<?> getObjectType()
Specified by:
getObjectType in interface FactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>
Specified by:
getObjectType in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>

doInit

protected void doInit()
Specified by:
doInit in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>

setRemoteDistributedSystemId

public void setRemoteDistributedSystemId(int remoteDistributedSystemId)

setEventFilters

public void setEventFilters(List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> gatewayEventFilters)

setTransportFilters

public void setTransportFilters(List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> gatewayTransportFilters)

setAlertThreshold

public void setAlertThreshold(Integer alertThreshold)

setEnableBatchConflation

public void setEnableBatchConflation(Boolean enableBatchConflation)

setBatchSize

public void setBatchSize(Integer batchSize)

setBatchTimeInterval

public void setBatchTimeInterval(Integer batchTimeInterval)

setDiskStoreRef

public void setDiskStoreRef(String diskStoreRef)

setDiskSynchronous

public void setDiskSynchronous(Boolean diskSynchronous)

setDispatcherThreads

public void setDispatcherThreads(Integer dispatcherThreads)

setManualStart

public void setManualStart(Boolean manualStart)

setMaximumQueueMemory

public void setMaximumQueueMemory(Integer maximumQueueMemory)

setOrderPolicy

public void setOrderPolicy(String orderPolicy)

setParallel

public void setParallel(Boolean parallel)

setPersistent

public void setPersistent(Boolean persistent)

setSocketBufferSize

public void setSocketBufferSize(Integer socketBufferSize)

setSocketReadTimeout

public void setSocketReadTimeout(Integer socketReadTimeout)