org.springframework.data.gemfire.wan
Class SmartLifecycleGatewaySender

java.lang.Object
  extended by org.springframework.data.gemfire.wan.SmartLifecycleGatewaySender
All Implemented Interfaces:
com.gemstone.gemfire.cache.wan.GatewaySender, Lifecycle, Phased, SmartLifecycle

public class SmartLifecycleGatewaySender
extends Object
implements com.gemstone.gemfire.cache.wan.GatewaySender, SmartLifecycle

A GatewaySender controlled by SmartLifecycle


Field Summary
 
Fields inherited from interface com.gemstone.gemfire.cache.wan.GatewaySender
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
SmartLifecycleGatewaySender(com.gemstone.gemfire.cache.wan.GatewaySender delegate, boolean autoStartup)
           
 
Method Summary
 void addGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter eventFilter)
           
 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 getPhase()
           
 int getRemoteDSId()
           
 int getSocketBufferSize()
           
 int getSocketReadTimeout()
           
 boolean isAutoStartup()
           
 boolean isBatchConflationEnabled()
           
 boolean isDiskSynchronous()
           
 boolean isManualStart()
           
 boolean isParallel()
           
 boolean isPaused()
           
 boolean isPersistenceEnabled()
           
 boolean isRunning()
           
 void pause()
           
 void removeGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter eventFilter)
           
 void resume()
           
 void start()
           
 void stop()
           
 void stop(Runnable callback)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SmartLifecycleGatewaySender

public SmartLifecycleGatewaySender(com.gemstone.gemfire.cache.wan.GatewaySender delegate,
                                   boolean autoStartup)
Method Detail

addGatewayEventFilter

public void addGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter eventFilter)
Specified by:
addGatewayEventFilter in interface com.gemstone.gemfire.cache.wan.GatewaySender

getAlertThreshold

public int getAlertThreshold()
Specified by:
getAlertThreshold 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

getDiskStoreName

public String getDiskStoreName()
Specified by:
getDiskStoreName in interface com.gemstone.gemfire.cache.wan.GatewaySender

getDispatcherThreads

public int getDispatcherThreads()
Specified by:
getDispatcherThreads 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

getId

public String getId()
Specified by:
getId in interface com.gemstone.gemfire.cache.wan.GatewaySender

getMaximumQueueMemory

public int getMaximumQueueMemory()
Specified by:
getMaximumQueueMemory 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

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

isBatchConflationEnabled

public boolean isBatchConflationEnabled()
Specified by:
isBatchConflationEnabled 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

isPaused

public boolean isPaused()
Specified by:
isPaused in interface com.gemstone.gemfire.cache.wan.GatewaySender

isPersistenceEnabled

public boolean isPersistenceEnabled()
Specified by:
isPersistenceEnabled in interface com.gemstone.gemfire.cache.wan.GatewaySender

isRunning

public boolean isRunning()
Specified by:
isRunning in interface com.gemstone.gemfire.cache.wan.GatewaySender
Specified by:
isRunning in interface Lifecycle

pause

public void pause()
Specified by:
pause in interface com.gemstone.gemfire.cache.wan.GatewaySender

removeGatewayEventFilter

public void removeGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter eventFilter)
Specified by:
removeGatewayEventFilter in interface com.gemstone.gemfire.cache.wan.GatewaySender

resume

public void resume()
Specified by:
resume in interface com.gemstone.gemfire.cache.wan.GatewaySender

start

public void start()
Specified by:
start in interface com.gemstone.gemfire.cache.wan.GatewaySender
Specified by:
start in interface Lifecycle

stop

public void stop()
Specified by:
stop in interface com.gemstone.gemfire.cache.wan.GatewaySender
Specified by:
stop 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