org.springframework.data.gemfire.wan
Class GatewaySenderFactoryBean
java.lang.Object
org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>
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.
|
Constructor Summary |
GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)
Constructs an instance of the GatewaySenderFactoryBean class initialized with a reference to the GemFire cache. |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
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
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