public class GatewaySenderFactoryBean extends AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>
FactoryBean
for creating a parallel or serial GemFire GatewaySender
.Cache
,
GemFireCache
,
GatewaySender
,
GatewaySenderFactory
,
AbstractWANComponentFactoryBean
cache, factory, logger
DEFAULT_SINGLETON
OBJECT_TYPE_ATTRIBUTE
Constructor and Description |
---|
GatewaySenderFactoryBean() |
GatewaySenderFactoryBean(org.apache.geode.cache.GemFireCache cache)
Constructs an instance of the
GatewaySenderFactoryBean class initialized with a reference to
the GemFire Cache used to configured and initialized a GemFire GatewaySender . |
Modifier and Type | Method and Description |
---|---|
protected void |
doInit() |
Integer |
getAlertThreshold() |
Boolean |
getBatchConflationEnabled() |
Integer |
getBatchSize() |
Integer |
getBatchTimeInterval() |
String |
getDiskStoreReference() |
Boolean |
getDiskSynchronous() |
Integer |
getDispatcherThreads() |
List<org.apache.geode.cache.wan.GatewayEventFilter> |
getEventFilters() |
org.apache.geode.cache.wan.GatewayEventSubstitutionFilter |
getEventSubstitutionFilter() |
org.apache.geode.cache.wan.GatewaySender |
getGatewaySender() |
Integer |
getMaximumQueueMemory() |
org.apache.geode.cache.wan.GatewaySender |
getObject() |
Class<?> |
getObjectType() |
org.apache.geode.cache.wan.GatewaySender.OrderPolicy |
getOrderPolicy() |
List<String> |
getRegions() |
int |
getRemoteDistributedSystemId() |
Integer |
getSocketBufferSize() |
Integer |
getSocketReadTimeout() |
List<org.apache.geode.cache.wan.GatewayTransportFilter> |
getTransportFilters() |
boolean |
isManualStart() |
boolean |
isNotPersistent() |
boolean |
isParallelGatewaySender() |
boolean |
isPersistent() |
boolean |
isSerialGatewaySender() |
void |
setAlertThreshold(Integer alertThreshold) |
void |
setBatchConflationEnabled(Boolean batchConflationEnabled) |
void |
setBatchSize(Integer batchSize) |
void |
setBatchTimeInterval(Integer batchTimeInterval) |
void |
setDiskStoreRef(String diskStoreRef) |
void |
setDiskStoreReference(String diskStoreReference) |
void |
setDiskSynchronous(Boolean diskSynchronous) |
void |
setDispatcherThreads(Integer dispatcherThreads) |
void |
setEventFilters(List<org.apache.geode.cache.wan.GatewayEventFilter> eventFilters) |
void |
setEventSubstitutionFilter(org.apache.geode.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter) |
void |
setGatewaySender(org.apache.geode.cache.wan.GatewaySender gatewaySender) |
void |
setGatewaySenderConfigurers(List<GatewaySenderConfigurer> gatewaySenderConfigurers) |
void |
setManualStart(boolean manualStart) |
void |
setManualStart(Boolean manualStart) |
void |
setMaximumQueueMemory(Integer maximumQueueMemory) |
void |
setOrderPolicy(org.apache.geode.cache.wan.GatewaySender.OrderPolicy orderPolicy) |
void |
setOrderPolicy(OrderPolicyType orderPolicy) |
void |
setParallel(Boolean parallel) |
void |
setPersistent(Boolean persistent) |
void |
setRegions(List<String> regions) |
void |
setRegions(String[] regions) |
void |
setRemoteDistributedSystemId(int remoteDistributedSystemId) |
void |
setSocketBufferSize(Integer socketBufferSize) |
void |
setSocketReadTimeout(Integer socketReadTimeout) |
void |
setTransportFilters(List<org.apache.geode.cache.wan.GatewayTransportFilter> transportFilters) |
afterPropertiesSet, destroy, getCache, getName, setBeanName, setCache, setFactory, setName
getBeanClassLoader, getBeanFactory, getBeanName, getLog, isSingleton, logDebug, logDebug, logError, logError, logInfo, logInfo, logWarning, logWarning, newLog, setBeanClassLoader, setBeanFactory
public GatewaySenderFactoryBean()
public GatewaySenderFactoryBean(org.apache.geode.cache.GemFireCache cache)
GatewaySenderFactoryBean
class initialized with a reference to
the GemFire Cache
used to configured and initialized a GemFire GatewaySender
.cache
- reference to the GemFire Cache
used to create the GemFire GatewaySender
.Cache
protected void doInit()
doInit
in class AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>
public org.apache.geode.cache.wan.GatewaySender getObject() throws Exception
Exception
public Class<?> getObjectType()
public void setGatewaySender(org.apache.geode.cache.wan.GatewaySender gatewaySender)
public org.apache.geode.cache.wan.GatewaySender getGatewaySender()
public void setGatewaySenderConfigurers(List<GatewaySenderConfigurer> gatewaySenderConfigurers)
public void setAlertThreshold(Integer alertThreshold)
public Integer getAlertThreshold()
public void setBatchConflationEnabled(Boolean batchConflationEnabled)
public Boolean getBatchConflationEnabled()
public void setBatchSize(Integer batchSize)
public Integer getBatchSize()
public void setBatchTimeInterval(Integer batchTimeInterval)
public Integer getBatchTimeInterval()
public void setDiskStoreRef(String diskStoreRef)
public void setDiskStoreReference(String diskStoreReference)
public String getDiskStoreReference()
public void setDiskSynchronous(Boolean diskSynchronous)
public Boolean getDiskSynchronous()
public void setDispatcherThreads(Integer dispatcherThreads)
public Integer getDispatcherThreads()
public void setEventFilters(List<org.apache.geode.cache.wan.GatewayEventFilter> eventFilters)
public List<org.apache.geode.cache.wan.GatewayEventFilter> getEventFilters()
public void setEventSubstitutionFilter(org.apache.geode.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter)
public org.apache.geode.cache.wan.GatewayEventSubstitutionFilter getEventSubstitutionFilter()
public void setManualStart(boolean manualStart)
public void setManualStart(Boolean manualStart)
public boolean isManualStart()
public void setMaximumQueueMemory(Integer maximumQueueMemory)
public Integer getMaximumQueueMemory()
public void setOrderPolicy(org.apache.geode.cache.wan.GatewaySender.OrderPolicy orderPolicy)
public void setOrderPolicy(OrderPolicyType orderPolicy)
public org.apache.geode.cache.wan.GatewaySender.OrderPolicy getOrderPolicy()
public void setParallel(Boolean parallel)
public boolean isParallelGatewaySender()
public boolean isSerialGatewaySender()
public void setPersistent(Boolean persistent)
public boolean isPersistent()
public boolean isNotPersistent()
public void setRemoteDistributedSystemId(int remoteDistributedSystemId)
public void setRegions(String[] regions)
public int getRemoteDistributedSystemId()
public void setSocketBufferSize(Integer socketBufferSize)
public Integer getSocketBufferSize()
public void setSocketReadTimeout(Integer socketReadTimeout)
public Integer getSocketReadTimeout()
public void setTransportFilters(List<org.apache.geode.cache.wan.GatewayTransportFilter> transportFilters)
public List<org.apache.geode.cache.wan.GatewayTransportFilter> getTransportFilters()
Copyright © 2011–2019 Pivotal Software, Inc.. All rights reserved.