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()