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, Lifecycle, Phased, SmartLifecycle

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

FactoryBean for creating a parallel or serial GemFire GatewaySender.


Field Summary
 
Fields inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean
cache, factory, log, VALID_ORDER_POLICIES
 
Constructor Summary
GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)
          Constructs an instance of the GatewaySenderFactoryBean class initialized with a reference to the GemFire cache.
 
Method Summary
protected  void doInit()
           
 com.gemstone.gemfire.cache.wan.GatewaySender getObject()
           
 Class<?> getObjectType()
           
 int getPhase()
           
 boolean isAutoStartup()
           
 boolean isNotPersistent()
           
 boolean isParallelGatewaySender()
           
 boolean isPersistent()
           
 boolean isRunning()
           
 boolean isSerialGatewaySender()
           
 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)
           
 void start()
           
 void stop()
           
 void stop(Runnable callback)
           
 
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)
Constructs an instance of the GatewaySenderFactoryBean class initialized with a reference to the GemFire cache.

Parameters:
cache - the Gemfire cache reference.
See Also:
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)

isSerialGatewaySender

public boolean isSerialGatewaySender()

isParallelGatewaySender

public boolean isParallelGatewaySender()

setPersistent

public void setPersistent(Boolean persistent)

isNotPersistent

public boolean isNotPersistent()

isPersistent

public boolean isPersistent()

setSocketBufferSize

public void setSocketBufferSize(Integer socketBufferSize)

setSocketReadTimeout

public void setSocketReadTimeout(Integer socketReadTimeout)

start

public void start()
Specified by:
start in interface Lifecycle

stop

public void stop()
Specified by:
stop in interface Lifecycle

isRunning

public boolean isRunning()
Specified by:
isRunning in interface Lifecycle

getPhase

public int getPhase()
Specified by:
getPhase in interface Phased

isAutoStartup

public boolean isAutoStartup()
Specified by:
isAutoStartup in interface SmartLifecycle

stop

public void stop(Runnable callback)
Specified by:
stop in interface SmartLifecycle