Package org.springframework.data.gemfire.wan

Class GatewaySenderWrapper

java.lang.Object
org.springframework.data.gemfire.wan.GatewaySenderWrapper
All Implemented Interfaces:
org.apache.geode.cache.wan.GatewaySender
public class GatewaySenderWrapper extends Object implements org.apache.geode.cache.wan.GatewaySender
GatewaySenderWrapper is an Adapter around an Apache Geode GatewaySender providing the ability to control manual start and stop of the sender.
See Also:
  • GatewaySender

  • Constructor Details

    • GatewaySenderWrapper

      public GatewaySenderWrapper(org.apache.geode.cache.wan.GatewaySender gatewaySender)
      Constructs an instance of GatewaySenderWrapper initialized with the given GatewaySender to adapt.
      Parameters:
      gatewaySender - GatewaySender to adapt.
      Throws:
      IllegalArgumentException - if GatewaySender is null.
      See Also:
      • GatewaySender

  • Method Details

    • isBatchConflationEnabled

      public boolean isBatchConflationEnabled()
      Specified by:
      isBatchConflationEnabled in interface org.apache.geode.cache.wan.GatewaySender

    • isDiskSynchronous

      public boolean isDiskSynchronous()
      Specified by:
      isDiskSynchronous in interface org.apache.geode.cache.wan.GatewaySender

    • isManualStart

      public boolean isManualStart()
      Specified by:
      isManualStart in interface org.apache.geode.cache.wan.GatewaySender

    • isParallel

      public boolean isParallel()
      Specified by:
      isParallel in interface org.apache.geode.cache.wan.GatewaySender

    • isPaused

      public boolean isPaused()
      Specified by:
      isPaused in interface org.apache.geode.cache.wan.GatewaySender

    • isPersistenceEnabled

      public boolean isPersistenceEnabled()
      Specified by:
      isPersistenceEnabled in interface org.apache.geode.cache.wan.GatewaySender

    • isRunning

      public boolean isRunning()
      Specified by:
      isRunning in interface org.apache.geode.cache.wan.GatewaySender

    • getAlertThreshold

      public int getAlertThreshold()
      Specified by:
      getAlertThreshold in interface org.apache.geode.cache.wan.GatewaySender

    • getBatchSize

      public int getBatchSize()
      Specified by:
      getBatchSize in interface org.apache.geode.cache.wan.GatewaySender

    • getBatchTimeInterval

      public int getBatchTimeInterval()
      Specified by:
      getBatchTimeInterval in interface org.apache.geode.cache.wan.GatewaySender

    • getDiskStoreName

      public String getDiskStoreName()
      Specified by:
      getDiskStoreName in interface org.apache.geode.cache.wan.GatewaySender

    • getDispatcherThreads

      public int getDispatcherThreads()
      Specified by:
      getDispatcherThreads in interface org.apache.geode.cache.wan.GatewaySender

    • getEnforceThreadsConnectSameReceiver

      public boolean getEnforceThreadsConnectSameReceiver()
      Specified by:
      getEnforceThreadsConnectSameReceiver in interface org.apache.geode.cache.wan.GatewaySender

    • getGatewayEventFilters

      public List<org.apache.geode.cache.wan.GatewayEventFilter> getGatewayEventFilters()
      Specified by:
      getGatewayEventFilters in interface org.apache.geode.cache.wan.GatewaySender

    • getGatewayEventSubstitutionFilter

      public org.apache.geode.cache.wan.GatewayEventSubstitutionFilter getGatewayEventSubstitutionFilter()
      Specified by:
      getGatewayEventSubstitutionFilter in interface org.apache.geode.cache.wan.GatewaySender

    • getGatewayTransportFilters

      public List<org.apache.geode.cache.wan.GatewayTransportFilter> getGatewayTransportFilters()
      Specified by:
      getGatewayTransportFilters in interface org.apache.geode.cache.wan.GatewaySender

    • getId

      public String getId()
      Specified by:
      getId in interface org.apache.geode.cache.wan.GatewaySender

    • setManualStart

      public void setManualStart(boolean manualStart)

    • getMaxParallelismForReplicatedRegion

      public int getMaxParallelismForReplicatedRegion()
      Specified by:
      getMaxParallelismForReplicatedRegion in interface org.apache.geode.cache.wan.GatewaySender

    • getMaximumQueueMemory

      public int getMaximumQueueMemory()
      Specified by:
      getMaximumQueueMemory in interface org.apache.geode.cache.wan.GatewaySender

    • getOrderPolicy

      public org.apache.geode.cache.wan.GatewaySender.OrderPolicy getOrderPolicy()
      Specified by:
      getOrderPolicy in interface org.apache.geode.cache.wan.GatewaySender

    • getRemoteDSId

      public int getRemoteDSId()
      Specified by:
      getRemoteDSId in interface org.apache.geode.cache.wan.GatewaySender

    • getSocketBufferSize

      public int getSocketBufferSize()
      Specified by:
      getSocketBufferSize in interface org.apache.geode.cache.wan.GatewaySender

    • getSocketReadTimeout

      public int getSocketReadTimeout()
      Specified by:
      getSocketReadTimeout in interface org.apache.geode.cache.wan.GatewaySender

    • addGatewayEventFilter

      public void addGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)
      Specified by:
      addGatewayEventFilter in interface org.apache.geode.cache.wan.GatewaySender

    • mustGroupTransactionEvents

      public boolean mustGroupTransactionEvents()
      Specified by:
      mustGroupTransactionEvents in interface org.apache.geode.cache.wan.GatewaySender

    • removeGatewayEventFilter

      public void removeGatewayEventFilter(org.apache.geode.cache.wan.GatewayEventFilter filter)
      Specified by:
      removeGatewayEventFilter in interface org.apache.geode.cache.wan.GatewaySender

    • destroy

      public void destroy()
      Specified by:
      destroy in interface org.apache.geode.cache.wan.GatewaySender

    • pause

      public void pause()
      Specified by:
      pause in interface org.apache.geode.cache.wan.GatewaySender

    • rebalance

      public void rebalance()
      Specified by:
      rebalance in interface org.apache.geode.cache.wan.GatewaySender

    • resume

      public void resume()
      Specified by:
      resume in interface org.apache.geode.cache.wan.GatewaySender

    • start

      public void start()
      Specified by:
      start in interface org.apache.geode.cache.wan.GatewaySender

    • startWithCleanQueue

      public void startWithCleanQueue()
      Specified by:
      startWithCleanQueue in interface org.apache.geode.cache.wan.GatewaySender

    • stop

      public void stop()
      Specified by:
      stop in interface org.apache.geode.cache.wan.GatewaySender

    • toString

      public String toString()
      Overrides:
      toString in class Object