Package org.springframework.data.gemfire.wan

Class GatewaySenderFactoryBean

java.lang.Object
org.springframework.data.gemfire.support.AbstractFactoryBeanSupport<T>
org.springframework.data.gemfire.wan.AbstractWANComponentFactoryBean<GatewaySender>
org.springframework.data.gemfire.wan.GatewaySenderFactoryBean
All Implemented Interfaces:
Aware, BeanClassLoaderAware, BeanFactoryAware, BeanNameAware, DisposableBean, FactoryBean<GatewaySender>, InitializingBean
public class GatewaySenderFactoryBean extends AbstractWANComponentFactoryBean<GatewaySender>
Spring FactoryBean used to construct, configure and initialize parallel and serial GatewaySenders.
Since:
1.2.2
Author:
David Turanski, John Blum, Udo Kohlmeyer
See Also:

  • Constructor Details

    • GatewaySenderFactoryBean

      public GatewaySenderFactoryBean()

    • GatewaySenderFactoryBean

      public GatewaySenderFactoryBean(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:

  • Method Details

    • doInit

      protected void doInit()
      Specified by:
      doInit in class AbstractWANComponentFactoryBean<GatewaySender>

    • getObject

      public GatewaySender getObject() throws Exception
      Throws:
      Exception

    • getObjectType

      public Class<?> getObjectType()

    • setGatewaySender

      public void setGatewaySender(@Nullable GatewaySender gatewaySender)

    • getGatewaySender

      @Nullable public 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<GatewayEventFilter> eventFilters)

    • getEventFilters

      public List<GatewayEventFilter> getEventFilters()

    • setEventSubstitutionFilter

      public void setEventSubstitutionFilter(GatewayEventSubstitutionFilter eventSubstitutionFilter)

    • getEventSubstitutionFilter

      public 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(GatewaySender.OrderPolicy orderPolicy)

    • setOrderPolicy

      public void setOrderPolicy(OrderPolicyType orderPolicy)

    • getOrderPolicy

      public 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<GatewayTransportFilter> transportFilters)

    • getTransportFilters

      public List<GatewayTransportFilter> getTransportFilters()