org.springframework.data.gemfire.wan
Class GatewaySenderWrapper

java.lang.Object
  extended by 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

Created by dturanski on 9/16/13.


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_PERSISTENCE_ENABLED, DEFAULT_SOCKET_BUFFER_SIZE, DEFAULT_SOCKET_READ_TIMEOUT, EARLY_ACK, GATEWAY_CONNECTION_IDLE_TIMEOUT, GATEWAY_CONNECTION_READ_TIMEOUT, GATEWAY_SENDER_TIMEOUT, QUEUE_OPLOG_SIZE, REMOVE_FROM_QUEUE_ON_EXCEPTION
 
Constructor Summary
GatewaySenderWrapper(com.gemstone.gemfire.cache.wan.GatewaySender delegate)
           
 
Method Summary
 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()
           
 List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> getGatewayTransportFilters()
           
 String getId()
           
 int getMaximumQueueMemory()
           
 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 removeGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)
           
 void resume()
           
 void setManualStart(boolean manualStart)
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

GatewaySenderWrapper

public GatewaySenderWrapper(com.gemstone.gemfire.cache.wan.GatewaySender delegate)
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

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

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)