public class GatewaySenderWrapper extends Object implements com.gemstone.gemfire.cache.wan.GatewaySender
Gateway
,
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_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 and Description |
---|
GatewaySenderWrapper(com.gemstone.gemfire.cache.wan.GatewaySender gatewaySender) |
public GatewaySenderWrapper(com.gemstone.gemfire.cache.wan.GatewaySender gatewaySender)
public void start()
start
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public void stop()
stop
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public void pause()
pause
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public void resume()
resume
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isRunning()
isRunning
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isPaused()
isPaused
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public void addGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)
addGatewayEventFilter
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public void removeGatewayEventFilter(com.gemstone.gemfire.cache.wan.GatewayEventFilter filter)
removeGatewayEventFilter
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public String getId()
getId
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getRemoteDSId()
getRemoteDSId
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getSocketBufferSize()
getSocketBufferSize
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getSocketReadTimeout()
getSocketReadTimeout
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public String getDiskStoreName()
getDiskStoreName
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getMaximumQueueMemory()
getMaximumQueueMemory
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getBatchSize()
getBatchSize
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getBatchTimeInterval()
getBatchTimeInterval
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isBatchConflationEnabled()
isBatchConflationEnabled
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isPersistenceEnabled()
isPersistenceEnabled
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getAlertThreshold()
getAlertThreshold
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public List<com.gemstone.gemfire.cache.wan.GatewayEventFilter> getGatewayEventFilters()
getGatewayEventFilters
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public com.gemstone.gemfire.cache.wan.GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter()
getGatewayEventSubstitutionFilter
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public List<com.gemstone.gemfire.cache.wan.GatewayTransportFilter> getGatewayTransportFilters()
getGatewayTransportFilters
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isDiskSynchronous()
isDiskSynchronous
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isManualStart()
isManualStart
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public boolean isParallel()
isParallel
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public int getDispatcherThreads()
getDispatcherThreads
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public Gateway.OrderPolicy getOrderPolicy()
getOrderPolicy
in interface com.gemstone.gemfire.cache.wan.GatewaySender
public void setManualStart(boolean manualStart)
public int getMaxParallelismForReplicatedRegion()
getMaxParallelismForReplicatedRegion
in interface com.gemstone.gemfire.cache.wan.GatewaySender