org.springframework.data.gemfire.wan

Class GatewaySenderFactoryBean

java.lang.Object

org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<T>

org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>

org.springframework.data.gemfire.wan.GatewaySenderFactoryBean

All Implemented Interfaces:

Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<org.apache.geode.cache.wan.GatewaySender>, InitializingBean

public class GatewaySenderFactoryBean
extends AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>

Spring FactoryBean used to construct, configure and initialize parallel and serial GatewaySenders.

Since:

1.2.2

Author:

David Turanski, John Blum, Udo Kohlmeyer

See Also:

Cache, GemFireCache, GatewayEventFilter, GatewayEventSubstitutionFilter, GatewaySender, GatewaySenderFactory, GatewayTransportFilter, FactoryBean, GatewaySenderConfigurer, AbstractWANComponentFactoryBean

Field Summary

Fields inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean

cache, factory, logger

Fields inherited from class org.springframework.data.gemfire.support.AbstractFactoryBeanSupport

DEFAULT_SINGLETON

Fields inherited from interface org.springframework.beans.factory.FactoryBean

OBJECT_TYPE_ATTRIBUTE

Constructor Summary

Constructors

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.

Method Summary

Modifier and Type	Method and Description
protected void	doInit()
Integer	getAlertThreshold()
Boolean	getBatchConflationEnabled()
Integer	getBatchSize()
Integer	getBatchTimeInterval()
String	getDiskStoreReference()
Boolean	getDiskSynchronous()
Integer	getDispatcherThreads()
Boolean	getEnforceThreadsConnectToSameReceiver()
List<org.apache.geode.cache.wan.GatewayEventFilter>	getEventFilters()
org.apache.geode.cache.wan.GatewayEventSubstitutionFilter	getEventSubstitutionFilter()
org.apache.geode.cache.wan.GatewaySender	getGatewaySender()
Boolean	getGroupTransactionEvents()
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	setEnforceThreadsConnectToSameReceiver(Boolean enforceThreadsConnectToSameReceiver)
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	setGroupTransactionEvents(Boolean groupTransactionEvents)
void	setManualStart(boolean manualStart) Deprecated.
void	setManualStart(Boolean manualStart) Deprecated.
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)

Methods inherited from class org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean

afterPropertiesSet, destroy, getCache, getName, setBeanName, setCache, setFactory, setName

Methods inherited from class org.springframework.data.gemfire.support.AbstractFactoryBeanSupport

getBeanClassLoader, getBeanFactory, getBeanName, getLogger, getOptionalLogger, isDebugLoggingEnabled, isErrorLoggingEnabled, isInfoLoggingEnabled, isSingleton, isWarnLoggingEnabled, logDebug, logDebug, logError, logError, logInfo, logInfo, logWarning, logWarning, newLogger, setBeanClassLoader, setBeanFactory

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GatewaySenderFactoryBean

public GatewaySenderFactoryBean()

GatewaySenderFactoryBean

public 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.

Parameters:

cache - reference to the GemFire Cache used to create the GemFire GatewaySender.

See Also:

Cache

Method Detail

doInit

protected void doInit()

Specified by:

doInit in class AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>

getObject

public org.apache.geode.cache.wan.GatewaySender getObject()
                                                   throws Exception

Throws:

Exception

getObjectType

public Class<?> getObjectType()

setGatewaySender

public void setGatewaySender(@Nullable
                             org.apache.geode.cache.wan.GatewaySender gatewaySender)

getGatewaySender

@Nullable
public org.apache.geode.cache.wan.GatewaySender getGatewaySender()

setGatewaySenderConfigurers

public void setGatewaySenderConfigurers(@NonNull
                                        List<GatewaySenderConfigurer> gatewaySenderConfigurers)

setAlertThreshold

public void setAlertThreshold(Integer alertThreshold)

getAlertThreshold

public Integer getAlertThreshold()

setBatchConflationEnabled

public void setBatchConflationEnabled(Boolean batchConflationEnabled)

getBatchConflationEnabled

public Boolean getBatchConflationEnabled()

setBatchSize

public void setBatchSize(Integer batchSize)

getBatchSize

public Integer getBatchSize()

setBatchTimeInterval

public void setBatchTimeInterval(Integer batchTimeInterval)

getBatchTimeInterval

public Integer getBatchTimeInterval()

setDiskStoreRef

public void setDiskStoreRef(String diskStoreRef)

setDiskStoreReference

public void setDiskStoreReference(String diskStoreReference)

getDiskStoreReference

public String getDiskStoreReference()

setDiskSynchronous

public void setDiskSynchronous(Boolean diskSynchronous)

getDiskSynchronous

public Boolean getDiskSynchronous()

setDispatcherThreads

public void setDispatcherThreads(Integer dispatcherThreads)

getDispatcherThreads

public Integer getDispatcherThreads()

setEnforceThreadsConnectToSameReceiver

public void setEnforceThreadsConnectToSameReceiver(Boolean enforceThreadsConnectToSameReceiver)

getEnforceThreadsConnectToSameReceiver

public Boolean getEnforceThreadsConnectToSameReceiver()

setEventFilters

public void setEventFilters(List<org.apache.geode.cache.wan.GatewayEventFilter> eventFilters)

getEventFilters

public List<org.apache.geode.cache.wan.GatewayEventFilter> getEventFilters()

setEventSubstitutionFilter

public void setEventSubstitutionFilter(org.apache.geode.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter)

getEventSubstitutionFilter

public org.apache.geode.cache.wan.GatewayEventSubstitutionFilter getEventSubstitutionFilter()

setGroupTransactionEvents

public void setGroupTransactionEvents(Boolean groupTransactionEvents)

getGroupTransactionEvents

public Boolean getGroupTransactionEvents()

setManualStart

@Deprecated
public void setManualStart(boolean manualStart)

Deprecated.

setManualStart

@Deprecated
public void setManualStart(Boolean manualStart)

Deprecated.

isManualStart

public boolean isManualStart()

setMaximumQueueMemory

public void setMaximumQueueMemory(Integer maximumQueueMemory)

getMaximumQueueMemory

public Integer getMaximumQueueMemory()

setOrderPolicy

public void setOrderPolicy(org.apache.geode.cache.wan.GatewaySender.OrderPolicy orderPolicy)

setOrderPolicy

public void setOrderPolicy(OrderPolicyType orderPolicy)

getOrderPolicy

public org.apache.geode.cache.wan.GatewaySender.OrderPolicy getOrderPolicy()

setParallel

public void setParallel(Boolean parallel)

isParallelGatewaySender

public boolean isParallelGatewaySender()

isSerialGatewaySender

public boolean isSerialGatewaySender()

setPersistent

public void setPersistent(Boolean persistent)

isPersistent

public boolean isPersistent()

isNotPersistent

public boolean isNotPersistent()

setRemoteDistributedSystemId

public void setRemoteDistributedSystemId(int remoteDistributedSystemId)

setRegions

public void setRegions(String[] regions)

setRegions

public void setRegions(List<String> regions)

getRegions

public List<String> getRegions()

getRemoteDistributedSystemId

public int getRemoteDistributedSystemId()

setSocketBufferSize

public void setSocketBufferSize(Integer socketBufferSize)

getSocketBufferSize

public Integer getSocketBufferSize()

setSocketReadTimeout

public void setSocketReadTimeout(Integer socketReadTimeout)

getSocketReadTimeout

public Integer getSocketReadTimeout()

setTransportFilters

public void setTransportFilters(List<org.apache.geode.cache.wan.GatewayTransportFilter> transportFilters)

getTransportFilters

public List<org.apache.geode.cache.wan.GatewayTransportFilter> getTransportFilters()