org.springframework.data.gemfire.wan
Class SmartLifecycleGatewaySender
java.lang.Object
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
| 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 |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SmartLifecycleGatewaySender
public SmartLifecycleGatewaySender(com.gemstone.gemfire.cache.wan.GatewaySender delegate,
boolean autoStartup)
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