Package org.springframework.data.gemfire.wan

Class GatewaySenderFactoryBean

java.lang.Object
org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<T>
org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>
org.springframework.data.gemfire.wan.GatewaySenderFactoryBean
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<org.apache.geode.cache.wan.GatewaySender>, org.springframework.beans.factory.InitializingBean
public class GatewaySenderFactoryBean extends AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>
Spring FactoryBean used to construct, configure and initialize parallel and serial GatewaySenders.
Since:
1.2.2
See Also:

  • Constructor Details

    • GatewaySenderFactoryBean

      public GatewaySenderFactoryBean()

    • GatewaySenderFactoryBean

      public GatewaySenderFactoryBean(org.apache.geode.cache.GemFireCache cache)
      Constructs an instance of the GatewaySenderFactoryBean class initialized with a reference to the GemFire Cache used to configured and initialized a GemFire GatewaySender.
      Parameters:
      cache - reference to the GemFire Cache used to create the GemFire GatewaySender.
      See Also:
      • Cache

  • Method Details

    • doInit

      protected void doInit()
      Specified by:
      doInit in class AbstractWANComponentFactoryBean<org.apache.geode.cache.wan.GatewaySender>

    • getObject

      public org.apache.geode.cache.wan.GatewaySender getObject() throws Exception
      Throws:
      Exception

    • getObjectType

      public Class<?> getObjectType()

    • setGatewaySender

      public void setGatewaySender(@Nullable org.apache.geode.cache.wan.GatewaySender gatewaySender)

    • getGatewaySender

      @Nullable public org.apache.geode.cache.wan.GatewaySender getGatewaySender()

    • setGatewaySenderConfigurers

      public void setGatewaySenderConfigurers(@NonNull List<GatewaySenderConfigurer> gatewaySenderConfigurers)

    • setAlertThreshold

      public void setAlertThreshold(Integer alertThreshold)

    • getAlertThreshold

      public Integer getAlertThreshold()

    • setBatchConflationEnabled

      public void setBatchConflationEnabled(Boolean batchConflationEnabled)

    • getBatchConflationEnabled

      public Boolean getBatchConflationEnabled()

    • setBatchSize

      public void setBatchSize(Integer batchSize)

    • getBatchSize

      public Integer getBatchSize()

    • setBatchTimeInterval

      public void setBatchTimeInterval(Integer batchTimeInterval)

    • getBatchTimeInterval

      public Integer getBatchTimeInterval()

    • setDiskStoreRef

      public void setDiskStoreRef(String diskStoreRef)

    • setDiskStoreReference

      public void setDiskStoreReference(String diskStoreReference)

    • getDiskStoreReference

      public String getDiskStoreReference()

    • setDiskSynchronous

      public void setDiskSynchronous(Boolean diskSynchronous)

    • getDiskSynchronous

      public Boolean getDiskSynchronous()

    • setDispatcherThreads

      public void setDispatcherThreads(Integer dispatcherThreads)

    • getDispatcherThreads

      public Integer getDispatcherThreads()

    • setEnforceThreadsConnectToSameReceiver

      public void setEnforceThreadsConnectToSameReceiver(Boolean enforceThreadsConnectToSameReceiver)

    • getEnforceThreadsConnectToSameReceiver

      public Boolean getEnforceThreadsConnectToSameReceiver()

    • setEventFilters

      public void setEventFilters(List<org.apache.geode.cache.wan.GatewayEventFilter> eventFilters)

    • getEventFilters

      public List<org.apache.geode.cache.wan.GatewayEventFilter> getEventFilters()

    • setEventSubstitutionFilter

      public void setEventSubstitutionFilter(org.apache.geode.cache.wan.GatewayEventSubstitutionFilter eventSubstitutionFilter)

    • getEventSubstitutionFilter

      public org.apache.geode.cache.wan.GatewayEventSubstitutionFilter getEventSubstitutionFilter()

    • setGroupTransactionEvents

      public void setGroupTransactionEvents(Boolean groupTransactionEvents)

    • getGroupTransactionEvents

      public Boolean getGroupTransactionEvents()

    • setManualStart

      @Deprecated public void setManualStart(boolean manualStart)
      Deprecated.

    • setManualStart

      @Deprecated public void setManualStart(Boolean manualStart)
      Deprecated.

    • isManualStart

      public boolean isManualStart()

    • setMaximumQueueMemory

      public void setMaximumQueueMemory(Integer maximumQueueMemory)

    • getMaximumQueueMemory

      public Integer getMaximumQueueMemory()

    • setOrderPolicy

      public void setOrderPolicy(org.apache.geode.cache.wan.GatewaySender.OrderPolicy orderPolicy)

    • setOrderPolicy

      public void setOrderPolicy(OrderPolicyType orderPolicy)

    • getOrderPolicy

      public org.apache.geode.cache.wan.GatewaySender.OrderPolicy getOrderPolicy()

    • setParallel

      public void setParallel(Boolean parallel)

    • isParallelGatewaySender

      public boolean isParallelGatewaySender()

    • isSerialGatewaySender

      public boolean isSerialGatewaySender()

    • setPersistent

      public void setPersistent(Boolean persistent)

    • isPersistent

      public boolean isPersistent()

    • isNotPersistent

      public boolean isNotPersistent()

    • setRemoteDistributedSystemId

      public void setRemoteDistributedSystemId(int remoteDistributedSystemId)

    • setRegions

      public void setRegions(String[] regions)

    • setRegions

      public void setRegions(List<String> regions)

    • getRegions

      public List<String> getRegions()

    • getRemoteDistributedSystemId

      public int getRemoteDistributedSystemId()

    • setSocketBufferSize

      public void setSocketBufferSize(Integer socketBufferSize)

    • getSocketBufferSize

      public Integer getSocketBufferSize()

    • setSocketReadTimeout

      public void setSocketReadTimeout(Integer socketReadTimeout)

    • getSocketReadTimeout

      public Integer getSocketReadTimeout()

    • setTransportFilters

      public void setTransportFilters(List<org.apache.geode.cache.wan.GatewayTransportFilter> transportFilters)

    • getTransportFilters

      public List<org.apache.geode.cache.wan.GatewayTransportFilter> getTransportFilters()