Package org.springframework.data.gemfire.wan

Class GatewaySenderWrapper

java.lang.Object

org.springframework.data.gemfire.wan.GatewaySenderWrapper

All Implemented Interfaces:

GatewaySender

public class GatewaySenderWrapper
extends Object
implements GatewaySender

GatewaySenderWrapper is an Adapter around an Apache Geode GatewaySender providing the ability to control manual start and stop of the sender.

Author:

David Turanski, John Blum

See Also:

• GatewaySender

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.geode.cache.wan.GatewaySender

GatewaySender.OrderPolicy

Field Summary

Fields inherited from interface org.apache.geode.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_ENFORCE_THREADS_CONNECT_SAME_RECEIVER, DEFAULT_FORWARD_EXPIRATION_DESTROY, DEFAULT_IS_FOR_INTERNAL_USE, DEFAULT_IS_PARALLEL, DEFAULT_MANUAL_START, DEFAULT_MAXIMUM_QUEUE_MEMORY, DEFAULT_MUST_GROUP_TRANSACTION_EVENTS, 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, GET_TRANSACTION_EVENTS_FROM_QUEUE_RETRIES, GET_TRANSACTION_EVENTS_FROM_QUEUE_WAIT_TIME_MS, MINIMUM_SOCKET_READ_TIMEOUT, QUEUE_OPLOG_SIZE, REMOVE_FROM_QUEUE_ON_EXCEPTION

Constructor Summary

Constructors

Constructor	Description
GatewaySenderWrapper(GatewaySender gatewaySender)	Constructs an instance of GatewaySenderWrapper initialized with the given GatewaySender to adapt.

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

GatewaySenderWrapper

public GatewaySenderWrapper(GatewaySender gatewaySender)

Constructs an instance of GatewaySenderWrapper initialized with the given GatewaySender to adapt.

Parameters:

gatewaySender - GatewaySender to adapt.

Throws:

IllegalArgumentException - if GatewaySender is null.

See Also:

• GatewaySender

Method Details

isBatchConflationEnabled

public boolean isBatchConflationEnabled()

Specified by:

isBatchConflationEnabled in interface GatewaySender

isDiskSynchronous

public boolean isDiskSynchronous()

Specified by:

isDiskSynchronous in interface GatewaySender

isManualStart

public boolean isManualStart()

Specified by:

isManualStart in interface GatewaySender

isParallel

public boolean isParallel()

Specified by:

isParallel in interface GatewaySender

isPaused

public boolean isPaused()

Specified by:

isPaused in interface GatewaySender

isPersistenceEnabled

public boolean isPersistenceEnabled()

Specified by:

isPersistenceEnabled in interface GatewaySender

isRunning

public boolean isRunning()

Specified by:

isRunning in interface GatewaySender

getAlertThreshold

public int getAlertThreshold()

Specified by:

getAlertThreshold in interface GatewaySender

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface GatewaySender

getBatchTimeInterval

public int getBatchTimeInterval()

Specified by:

getBatchTimeInterval in interface GatewaySender

getDiskStoreName

public String getDiskStoreName()

Specified by:

getDiskStoreName in interface GatewaySender

getDispatcherThreads

public int getDispatcherThreads()

Specified by:

getDispatcherThreads in interface GatewaySender

getEnforceThreadsConnectSameReceiver

public boolean getEnforceThreadsConnectSameReceiver()

Specified by:

getEnforceThreadsConnectSameReceiver in interface GatewaySender

getGatewayEventFilters

public List<GatewayEventFilter> getGatewayEventFilters()

Specified by:

getGatewayEventFilters in interface GatewaySender

getGatewayEventSubstitutionFilter

public GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter()

Specified by:

getGatewayEventSubstitutionFilter in interface GatewaySender

getGatewayTransportFilters

public List<GatewayTransportFilter> getGatewayTransportFilters()

Specified by:

getGatewayTransportFilters in interface GatewaySender

getId

public String getId()

Specified by:

getId in interface GatewaySender

setManualStart

public void setManualStart(boolean manualStart)

getMaxParallelismForReplicatedRegion

public int getMaxParallelismForReplicatedRegion()

Specified by:

getMaxParallelismForReplicatedRegion in interface GatewaySender

getMaximumQueueMemory

public int getMaximumQueueMemory()

Specified by:

getMaximumQueueMemory in interface GatewaySender

getOrderPolicy

public GatewaySender.OrderPolicy getOrderPolicy()

Specified by:

getOrderPolicy in interface GatewaySender

getRemoteDSId

public int getRemoteDSId()

Specified by:

getRemoteDSId in interface GatewaySender

getSocketBufferSize

public int getSocketBufferSize()

Specified by:

getSocketBufferSize in interface GatewaySender

getSocketReadTimeout

public int getSocketReadTimeout()

Specified by:

getSocketReadTimeout in interface GatewaySender

addGatewayEventFilter

public void addGatewayEventFilter(GatewayEventFilter filter)

Specified by:

addGatewayEventFilter in interface GatewaySender

mustGroupTransactionEvents

public boolean mustGroupTransactionEvents()

Specified by:

mustGroupTransactionEvents in interface GatewaySender

removeGatewayEventFilter

public void removeGatewayEventFilter(GatewayEventFilter filter)

Specified by:

removeGatewayEventFilter in interface GatewaySender

destroy

public void destroy()

Specified by:

destroy in interface GatewaySender

pause

public void pause()

Specified by:

pause in interface GatewaySender

rebalance

public void rebalance()

Specified by:

rebalance in interface GatewaySender

resume

public void resume()

Specified by:

resume in interface GatewaySender

start

public void start()

Specified by:

start in interface GatewaySender

startWithCleanQueue

public void startWithCleanQueue()

Specified by:

startWithCleanQueue in interface GatewaySender

stop

public void stop()

Specified by:

stop in interface GatewaySender

toString

public String toString()

Overrides:

toString in class Object