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 GemFire GatewaySender.

Field Summary

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

cache, factory, log

Constructor Summary

GatewaySenderFactoryBean(com.gemstone.gemfire.cache.Cache cache)

Method Summary

protected void	doInit()
com.gemstone.gemfire.cache.wan.GatewaySender	getObject()
Class<?>	getObjectType()
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
void	setAlertThreshold(Integer alertThreshold)
void	setBatchSize(Integer batchSize)
void	setBatchTimeInterval(Integer batchTimeInterval)
void	setDiskStoreRef(String diskStoreRef)
void	setDiskSynchronous(Boolean diskSynchronous)
void	setDispatcherThreads(Integer dispatcherThreads)
void	setEnableBatchConflation(Boolean enableBatchConflation)
void	setEventFilters(List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> gatewayEventFilters)
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(com.gemstone.gemfire.cache.Cache cache)

Parameters:

cache - the Gemfire 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>

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)

setPersistent

public void setPersistent(Boolean persistent)

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