org.springframework.data.gemfire.wan

Class GatewaySenderWrapper

java.lang.Object

org.springframework.data.gemfire.wan.GatewaySenderWrapper

All Implemented Interfaces:

org.apache.geode.cache.wan.GatewaySender

public class GatewaySenderWrapper
extends Object
implements org.apache.geode.cache.wan.GatewaySender

GatewaySenderWrapper is an Adapter around a GatewaySender providing the ability to control manual start and stop.

Author:

David Turanski, John Blum

See Also:

Gateway, GatewaySender

Nested Class Summary

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

org.apache.geode.cache.wan.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_FORWARD_EXPIRATION_DESTROY, 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(org.apache.geode.cache.wan.GatewaySender gatewaySender) Constructs an instance of GatewaySenderWrapper initialized with the given GatewaySender to adapt.

Method Summary

Modifier and Type	Method and Description
void	addGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)
void	destroy()
int	getAlertThreshold()
int	getBatchSize()
int	getBatchTimeInterval()
String	getDiskStoreName()
int	getDispatcherThreads()
List<org.apache.geode.cache.wan.GatewayEventFilter>	getGatewayEventFilters()
org.apache.geode.cache.wan.GatewayEventSubstitutionFilter	getGatewayEventSubstitutionFilter()
List<org.apache.geode.cache.wan.GatewayTransportFilter>	getGatewayTransportFilters()
String	getId()
int	getMaximumQueueMemory()
int	getMaxParallelismForReplicatedRegion()
org.apache.geode.cache.wan.GatewaySender.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(org.apache.geode.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(org.apache.geode.cache.wan.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 Detail

isBatchConflationEnabled

public boolean isBatchConflationEnabled()

Specified by:

isBatchConflationEnabled in interface org.apache.geode.cache.wan.GatewaySender

isDiskSynchronous

public boolean isDiskSynchronous()

Specified by:

isDiskSynchronous in interface org.apache.geode.cache.wan.GatewaySender

isManualStart

public boolean isManualStart()

Specified by:

isManualStart in interface org.apache.geode.cache.wan.GatewaySender

isParallel

public boolean isParallel()

Specified by:

isParallel in interface org.apache.geode.cache.wan.GatewaySender

isPaused

public boolean isPaused()

Specified by:

isPaused in interface org.apache.geode.cache.wan.GatewaySender

isPersistenceEnabled

public boolean isPersistenceEnabled()

Specified by:

isPersistenceEnabled in interface org.apache.geode.cache.wan.GatewaySender

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.apache.geode.cache.wan.GatewaySender

getAlertThreshold

public int getAlertThreshold()

Specified by:

getAlertThreshold in interface org.apache.geode.cache.wan.GatewaySender

getBatchSize

public int getBatchSize()

Specified by:

getBatchSize in interface org.apache.geode.cache.wan.GatewaySender

getBatchTimeInterval

public int getBatchTimeInterval()

Specified by:

getBatchTimeInterval in interface org.apache.geode.cache.wan.GatewaySender

getDiskStoreName

public String getDiskStoreName()

Specified by:

getDiskStoreName in interface org.apache.geode.cache.wan.GatewaySender

getDispatcherThreads

public int getDispatcherThreads()

Specified by:

getDispatcherThreads in interface org.apache.geode.cache.wan.GatewaySender

getGatewayEventFilters

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

Specified by:

getGatewayEventFilters in interface org.apache.geode.cache.wan.GatewaySender

getGatewayEventSubstitutionFilter

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

Specified by:

getGatewayEventSubstitutionFilter in interface org.apache.geode.cache.wan.GatewaySender

getGatewayTransportFilters

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

Specified by:

getGatewayTransportFilters in interface org.apache.geode.cache.wan.GatewaySender

getId

public String getId()

Specified by:

getId in interface org.apache.geode.cache.wan.GatewaySender

setManualStart

public void setManualStart(boolean manualStart)

getMaxParallelismForReplicatedRegion

public int getMaxParallelismForReplicatedRegion()

Specified by:

getMaxParallelismForReplicatedRegion in interface org.apache.geode.cache.wan.GatewaySender

getMaximumQueueMemory

public int getMaximumQueueMemory()

Specified by:

getMaximumQueueMemory in interface org.apache.geode.cache.wan.GatewaySender

getOrderPolicy

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

Specified by:

getOrderPolicy in interface org.apache.geode.cache.wan.GatewaySender

getRemoteDSId

public int getRemoteDSId()

Specified by:

getRemoteDSId in interface org.apache.geode.cache.wan.GatewaySender

getSocketBufferSize

public int getSocketBufferSize()

Specified by:

getSocketBufferSize in interface org.apache.geode.cache.wan.GatewaySender

getSocketReadTimeout

public int getSocketReadTimeout()

Specified by:

getSocketReadTimeout in interface org.apache.geode.cache.wan.GatewaySender

addGatewayEventFilter

public void addGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)

Specified by:

addGatewayEventFilter in interface org.apache.geode.cache.wan.GatewaySender

removeGatewayEventFilter

public void removeGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)

Specified by:

removeGatewayEventFilter in interface org.apache.geode.cache.wan.GatewaySender

destroy

public void destroy()

Specified by:

destroy in interface org.apache.geode.cache.wan.GatewaySender

pause

public void pause()

Specified by:

pause in interface org.apache.geode.cache.wan.GatewaySender

rebalance

public void rebalance()

Specified by:

rebalance in interface org.apache.geode.cache.wan.GatewaySender

resume

public void resume()

Specified by:

resume in interface org.apache.geode.cache.wan.GatewaySender

start

public void start()

Specified by:

start in interface org.apache.geode.cache.wan.GatewaySender

stop

public void stop()

Specified by:

stop in interface org.apache.geode.cache.wan.GatewaySender

toString

public String toString()

Overrides:

toString in class Object