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.

Since:

1.2.2

See Also:

SmartLifecycle, AbstractWANComponentFactoryBean, Cache, Gateway, GatewaySender, GatewaySenderFactory

Field Summary

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

cache, factory, log, VALID_ORDER_POLICIES

Constructor Summary

Constructors

Constructor and Description
GatewaySenderFactoryBean(Cache cache) Constructs an instance of the GatewaySenderFactoryBean class initialized with a reference to the GemFire cache.

Method Summary

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)

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(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>

setAlertThreshold

public void setAlertThreshold(Integer alertThreshold)

setBatchConflationEnabled

public void setBatchConflationEnabled(Boolean batchConflationEnabled)

setEnableBatchConflation

@Deprecated
public void setEnableBatchConflation(Boolean enableBatchConflation)

Deprecated. use setBatchConflationEnabled(Boolean)

Boolean value that determines whether GemFire should conflate messages.

Parameters:

enableBatchConflation - a boolean value indicating whether GemFire should conflate messages in the Queue.

See Also:

setBatchConflationEnabled(Boolean)

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)

setEventFilters

public void setEventFilters(List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> gatewayEventFilters)

setEventSubstitutionFilter

public void setEventSubstitutionFilter(com.gemstone.gemfire.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter)

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()

setRemoteDistributedSystemId

public void setRemoteDistributedSystemId(int remoteDistributedSystemId)

setSocketBufferSize

public void setSocketBufferSize(Integer socketBufferSize)

setSocketReadTimeout

public void setSocketReadTimeout(Integer socketReadTimeout)

setTransportFilters

public void setTransportFilters(List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> gatewayTransportFilters)

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface Phased

isRunning

public boolean isRunning()

Specified by:

isRunning in interface Lifecycle

start

public void start()

Specified by:

start in interface Lifecycle

stop

public void stop()

Specified by:

stop in interface Lifecycle

stop

public void stop(Runnable callback)

Specified by:

stop in interface SmartLifecycle