org.springframework.data.gemfire.wan

Class GatewaySenderWrapper

java.lang.Object

org.springframework.data.gemfire.wan.GatewaySenderWrapper

All Implemented Interfaces:

com.gemstone.gemfire.cache.wan.GatewaySender

public class GatewaySenderWrapper
extends Object
implements com.gemstone.gemfire.cache.wan.GatewaySender

Author:

David Turanski, John Blum

See Also:

Gateway, GatewaySender

Field Summary

Fields inherited from interface com.gemstone.gemfire.cache.wan.GatewaySender

CONNECTION_RETRY_INTERVAL, DEFAULT_ALERT_THRESHOLD, DEFAULT_BATCH_CONFLATION, DEFAULT_BATCH_SIZE, DEFAULT_BATCH_TIME_INTERVAL, DEFAULT_DISK_SYNCHRONOUS, DEFAULT_DISPATCHER_THREADS, DEFAULT_DISTRIBUTED_SYSTEM_ID, DEFAULT_IS_FOR_INTERNAL_USE, DEFAULT_IS_PARALLEL, DEFAULT_MANUAL_START, DEFAULT_MAXIMUM_QUEUE_MEMORY, DEFAULT_ORDER_POLICY, DEFAULT_PARALLELISM_REPLICATED_REGION, DEFAULT_PERSISTENCE_ENABLED, DEFAULT_SOCKET_BUFFER_SIZE, DEFAULT_SOCKET_READ_TIMEOUT, EARLY_ACK, GATEWAY_CONNECTION_IDLE_TIMEOUT, GATEWAY_CONNECTION_READ_TIMEOUT_PROPERTY, GATEWAY_SENDER_TIMEOUT, MINIMUM_SOCKET_READ_TIMEOUT, QUEUE_OPLOG_SIZE, REMOVE_FROM_QUEUE_ON_EXCEPTION

Constructor Summary

Constructors

Constructor and Description
GatewaySenderWrapper(com.gemstone.gemfire.cache.wan.GatewaySender gatewaySender)

Method Summary

Modifier and Type	Method and Description
void	addGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)
int	getAlertThreshold()
int	getBatchSize()
int	getBatchTimeInterval()
String	getDiskStoreName()
int	getDispatcherThreads()
List<com.gemstone.gemfire.cache.wan.GatewayEventFilter>	getGatewayEventFilters()
com.gemstone.gemfire.cache.wan.GatewayEventSubstitutionFilter	getGatewayEventSubstitutionFilter()
List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter>	getGatewayTransportFilters()
String	getId()
int	getMaximumQueueMemory()
int	getMaxParallelismForReplicatedRegion()
com.gemstone.gemfire.cache.util.Gateway.OrderPolicy	getOrderPolicy()
int	getRemoteDSId()
int	getSocketBufferSize()
int	getSocketReadTimeout()
boolean	isBatchConflationEnabled()
boolean	isDiskSynchronous()
boolean	isManualStart()
boolean	isParallel()
boolean	isPaused()
boolean	isPersistenceEnabled()
boolean	isRunning()
void	pause()
void	rebalance()
void	removeGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)
void	resume()
void	setManualStart(boolean manualStart)
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

GatewaySenderWrapper

public GatewaySenderWrapper(com.gemstone.gemfire.cache.wan.GatewaySender gatewaySender)

Method Detail

start

public void start()

Specified by:

start in interface com.gemstone.gemfire.cache.wan.GatewaySender

stop

public void stop()

Specified by:

stop in interface com.gemstone.gemfire.cache.wan.GatewaySender

pause

public void pause()

Specified by:

pause in interface com.gemstone.gemfire.cache.wan.GatewaySender

resume

public void resume()

Specified by:

resume in interface com.gemstone.gemfire.cache.wan.GatewaySender

rebalance

public void rebalance()

Specified by:

rebalance in interface com.gemstone.gemfire.cache.wan.GatewaySender

isRunning

public boolean isRunning()

Specified by:

isRunning in interface com.gemstone.gemfire.cache.wan.GatewaySender

isPaused

public boolean isPaused()

Specified by:

isPaused in interface com.gemstone.gemfire.cache.wan.GatewaySender

addGatewayEventFilter

public void addGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)

Specified by:

addGatewayEventFilter in interface com.gemstone.gemfire.cache.wan.GatewaySender

removeGatewayEventFilter

public void removeGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)

Specified by:

removeGatewayEventFilter in interface com.gemstone.gemfire.cache.wan.GatewaySender

getId

public String getId()

Specified by:

getId in interface com.gemstone.gemfire.cache.wan.GatewaySender

getRemoteDSId

public int getRemoteDSId()

Specified by:

getRemoteDSId in interface com.gemstone.gemfire.cache.wan.GatewaySender

getSocketBufferSize

public int getSocketBufferSize()

Specified by:

getSocketBufferSize in interface com.gemstone.gemfire.cache.wan.GatewaySender

getSocketReadTimeout

public int getSocketReadTimeout()

Specified by:

getSocketReadTimeout in interface com.gemstone.gemfire.cache.wan.GatewaySender

getDiskStoreName

public String getDiskStoreName()

Specified by:

getDiskStoreName in interface com.gemstone.gemfire.cache.wan.GatewaySender

getMaximumQueueMemory

public int getMaximumQueueMemory()

Specified by:

getMaximumQueueMemory in interface com.gemstone.gemfire.cache.wan.GatewaySender

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface com.gemstone.gemfire.cache.wan.GatewaySender

getBatchTimeInterval

public int getBatchTimeInterval()

Specified by:

getBatchTimeInterval in interface com.gemstone.gemfire.cache.wan.GatewaySender

isBatchConflationEnabled

public boolean isBatchConflationEnabled()

Specified by:

isBatchConflationEnabled in interface com.gemstone.gemfire.cache.wan.GatewaySender

isPersistenceEnabled

public boolean isPersistenceEnabled()

Specified by:

isPersistenceEnabled in interface com.gemstone.gemfire.cache.wan.GatewaySender

getAlertThreshold

public int getAlertThreshold()

Specified by:

getAlertThreshold in interface com.gemstone.gemfire.cache.wan.GatewaySender

getGatewayEventFilters

public List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> getGatewayEventFilters()

Specified by:

getGatewayEventFilters in interface com.gemstone.gemfire.cache.wan.GatewaySender

getGatewayEventSubstitutionFilter

public com.gemstone.gemfire.cache.wan.GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter()

Specified by:

getGatewayEventSubstitutionFilter in interface com.gemstone.gemfire.cache.wan.GatewaySender

getGatewayTransportFilters

public List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> getGatewayTransportFilters()

Specified by:

getGatewayTransportFilters in interface com.gemstone.gemfire.cache.wan.GatewaySender

isDiskSynchronous

public boolean isDiskSynchronous()

Specified by:

isDiskSynchronous in interface com.gemstone.gemfire.cache.wan.GatewaySender

isManualStart

public boolean isManualStart()

Specified by:

isManualStart in interface com.gemstone.gemfire.cache.wan.GatewaySender

isParallel

public boolean isParallel()

Specified by:

isParallel in interface com.gemstone.gemfire.cache.wan.GatewaySender

getDispatcherThreads

public int getDispatcherThreads()

Specified by:

getDispatcherThreads in interface com.gemstone.gemfire.cache.wan.GatewaySender

getOrderPolicy

public com.gemstone.gemfire.cache.util.Gateway.OrderPolicy getOrderPolicy()

Specified by:

getOrderPolicy in interface com.gemstone.gemfire.cache.wan.GatewaySender

setManualStart

public void setManualStart(boolean manualStart)

getMaxParallelismForReplicatedRegion

public int getMaxParallelismForReplicatedRegion()

Specified by:

getMaxParallelismForReplicatedRegion in interface com.gemstone.gemfire.cache.wan.GatewaySender

toString

public String toString()

Overrides:

toString in class Object