public class GatewaySenderFactoryBean extends AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender> implements SmartLifecycle
GatewaySender.SmartLifecycle,
AbstractWANComponentFactoryBean,
Cache,
Gateway,
GatewaySender,
GatewaySenderFactorycache, factory, log, VALID_ORDER_POLICIES| Constructor and Description |
|---|
GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)
Constructs an instance of the GatewaySenderFactoryBean class initialized with a reference to the GemFire cache.
|
| Modifier and Type | Method and Description |
|---|---|
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 |
setBatchConflationEnabled(Boolean batchConflationEnabled) |
void |
setBatchSize(Integer batchSize) |
void |
setBatchTimeInterval(Integer batchTimeInterval) |
void |
setDiskStoreRef(String diskStoreRef) |
void |
setDiskSynchronous(Boolean diskSynchronous) |
void |
setDispatcherThreads(Integer dispatcherThreads) |
void |
setEnableBatchConflation(Boolean enableBatchConflation)
Deprecated.
use setBatchConflationEnabled(Boolean)
|
void |
setEventFilters(List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> gatewayEventFilters) |
void |
setEventSubstitutionFilter(com.gemstone.gemfire.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter) |
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) |
afterPropertiesSet, destroy, getName, isSingleton, setBeanName, setFactory, setNamepublic GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)
cache - the Gemfire cache reference.Cachepublic com.gemstone.gemfire.cache.wan.GatewaySender getObject()
throws Exception
getObject in interface FactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>getObject in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>Exceptionpublic Class<?> getObjectType()
getObjectType in interface FactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>getObjectType in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>protected void doInit()
doInit in class AbstractWANComponentFactoryBean<com.gemstone.gemfire.cache.wan.GatewaySender>public void setAlertThreshold(Integer alertThreshold)
public void setBatchConflationEnabled(Boolean batchConflationEnabled)
@Deprecated public void setEnableBatchConflation(Boolean enableBatchConflation)
enableBatchConflation - a boolean value indicating whether GemFire should conflate messages in the Queue.setBatchConflationEnabled(Boolean)public void setBatchSize(Integer batchSize)
public void setBatchTimeInterval(Integer batchTimeInterval)
public void setDiskStoreRef(String diskStoreRef)
public void setDiskSynchronous(Boolean diskSynchronous)
public void setDispatcherThreads(Integer dispatcherThreads)
public void setEventFilters(List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> gatewayEventFilters)
public void setEventSubstitutionFilter(com.gemstone.gemfire.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter)
public void setManualStart(Boolean manualStart)
public void setMaximumQueueMemory(Integer maximumQueueMemory)
public void setOrderPolicy(String orderPolicy)
public void setParallel(Boolean parallel)
public boolean isSerialGatewaySender()
public boolean isParallelGatewaySender()
public void setPersistent(Boolean persistent)
public boolean isNotPersistent()
public boolean isPersistent()
public void setRemoteDistributedSystemId(int remoteDistributedSystemId)
public void setSocketBufferSize(Integer socketBufferSize)
public void setSocketReadTimeout(Integer socketReadTimeout)
public void setTransportFilters(List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> gatewayTransportFilters)
public boolean isAutoStartup()
isAutoStartup in interface SmartLifecyclepublic void stop(Runnable callback)
stop in interface SmartLifecycle