public class GatewaySenderWrapper extends ObjectSE implements org.apache.geode.cache.wan.GatewaySender
GatewaySenderWrapper
は、手動による開始と停止を制御する機能を提供する 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_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
コンストラクターと説明 |
---|
GatewaySenderWrapper(org.apache.geode.cache.wan.GatewaySender gatewaySender) 適応するために指定された GatewaySender で初期化された GatewaySenderWrapper のインスタンスを構築します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE
public GatewaySenderWrapper(org.apache.geode.cache.wan.GatewaySender gatewaySender)
GatewaySender
で初期化された GatewaySenderWrapper
のインスタンスを構築します。gatewaySender
- GatewaySender
に適応します。IllegalArgumentExceptionSE
- GatewaySender
が null の場合。GatewaySender
public boolean isBatchConflationEnabled()
org.apache.geode.cache.wan.GatewaySender
の isBatchConflationEnabled
public boolean isDiskSynchronous()
org.apache.geode.cache.wan.GatewaySender
の isDiskSynchronous
public boolean isManualStart()
org.apache.geode.cache.wan.GatewaySender
の isManualStart
public boolean isParallel()
org.apache.geode.cache.wan.GatewaySender
の isParallel
public boolean isPaused()
org.apache.geode.cache.wan.GatewaySender
の isPaused
public boolean isPersistenceEnabled()
org.apache.geode.cache.wan.GatewaySender
の isPersistenceEnabled
public boolean isRunning()
org.apache.geode.cache.wan.GatewaySender
の isRunning
public int getAlertThreshold()
org.apache.geode.cache.wan.GatewaySender
の getAlertThreshold
public int getBatchSize()
org.apache.geode.cache.wan.GatewaySender
の getBatchSize
public int getBatchTimeInterval()
org.apache.geode.cache.wan.GatewaySender
の getBatchTimeInterval
public StringSE getDiskStoreName()
org.apache.geode.cache.wan.GatewaySender
の getDiskStoreName
public int getDispatcherThreads()
org.apache.geode.cache.wan.GatewaySender
の getDispatcherThreads
public ListSE<org.apache.geode.cache.wan.GatewayEventFilter> getGatewayEventFilters()
org.apache.geode.cache.wan.GatewaySender
の getGatewayEventFilters
public org.apache.geode.cache.wan.GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter()
org.apache.geode.cache.wan.GatewaySender
の getGatewayEventSubstitutionFilter
public ListSE<org.apache.geode.cache.wan.GatewayTransportFilter> getGatewayTransportFilters()
org.apache.geode.cache.wan.GatewaySender
の getGatewayTransportFilters
public StringSE getId()
org.apache.geode.cache.wan.GatewaySender
の getId
public void setManualStart(boolean manualStart)
public int getMaxParallelismForReplicatedRegion()
org.apache.geode.cache.wan.GatewaySender
の getMaxParallelismForReplicatedRegion
public int getMaximumQueueMemory()
org.apache.geode.cache.wan.GatewaySender
の getMaximumQueueMemory
public org.apache.geode.cache.wan.GatewaySender.OrderPolicy getOrderPolicy()
org.apache.geode.cache.wan.GatewaySender
の getOrderPolicy
public int getRemoteDSId()
org.apache.geode.cache.wan.GatewaySender
の getRemoteDSId
public int getSocketBufferSize()
org.apache.geode.cache.wan.GatewaySender
の getSocketBufferSize
public int getSocketReadTimeout()
org.apache.geode.cache.wan.GatewaySender
の getSocketReadTimeout
public void addGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)
org.apache.geode.cache.wan.GatewaySender
の addGatewayEventFilter
public void removeGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)
org.apache.geode.cache.wan.GatewaySender
の removeGatewayEventFilter
public void destroy()
org.apache.geode.cache.wan.GatewaySender
の destroy
public void pause()
org.apache.geode.cache.wan.GatewaySender
の pause
public void rebalance()
org.apache.geode.cache.wan.GatewaySender
の rebalance
public void resume()
org.apache.geode.cache.wan.GatewaySender
の resume
public void start()
org.apache.geode.cache.wan.GatewaySender
の start
public void stop()
org.apache.geode.cache.wan.GatewaySender
の stop
public StringSE toString()
ObjectSE
の toStringSE
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.