Package org.openspaces.core.gateway

Class GatewayTargetsFactoryBean

java.lang.Object
org.openspaces.core.gateway.GatewayTargetsFactoryBean
All Implemented Interfaces:
SpaceCustomComponentFactoryBean, org.springframework.beans.factory.InitializingBean
public class GatewayTargetsFactoryBean extends Object implements SpaceCustomComponentFactoryBean, org.springframework.beans.factory.InitializingBean
A factory bean for creating a GatewaysPolicy instance.
Since:
8.0.3
Author:
Idan Moyal

  • Constructor Details

    • GatewayTargetsFactoryBean

      public GatewayTargetsFactoryBean()

  • Method Details

    • setLocalGatewayName

      public void setLocalGatewayName(String localGatewayName)
      Sets the local gateway name used for identification.
      Parameters:
      localGatewayName - The local gateway name.

    • getLocalGatewayName

      public String getLocalGatewayName()
      Returns:
      The local gateway name used for identification.

    • getGatewayTargets

      public List<GatewayTarget> getGatewayTargets()
      Returns:
      GatewayTargets configuration as array.

    • setGatewayTargets

      public void setGatewayTargets(List<GatewayTarget> gatewayTargets)
      Sets the gateway targets configuration.
      Parameters:
      gatewayTargets - The gateway targets.

    • setBulkSize

      public void setBulkSize(Integer bulkSize)
      Sets the number of packets in each replication bulk sent to this gateway.
      Parameters:
      bulkSize - number of packets in each replication bulk sent to this gateway.

    • setIdleTimeThreshold

      public void setIdleTimeThreshold(Long idleTimeThreshold)
      Sets the maximum time (in milliseconds) pending replication packets should wait before being replicated if setPendingOperationThreshold(Integer) has not been breached.
      Parameters:
      idleTimeThreshold - the maximum time (in milliseconds).

    • setPendingOperationThreshold

      public void setPendingOperationThreshold(Integer pendingOperationThreshold)
      Sets the threshold count for pending replication packets that once reached, the packets will be replicated using the setBulkSize(Integer).
      Parameters:
      pendingOperationThreshold - the threshold count.
      See Also:

    • setMaxRedoLogCapacity

      public void setMaxRedoLogCapacity(Long maxRedoLogCapacity)
      Sets limited redo log capacity for this gateway
      Parameters:
      maxRedoLogCapacity - redo log limit

    • setOnRedoLogCapacityExceeded

      public void setOnRedoLogCapacityExceeded(RedoLogCapacityExceededPolicy onRedoLogCapacityExceeded)
      Sets the behavior once the defined redo log capacity is exceeded, irrelevant if the capacity is unlimited.
      See Also:

    • setReplicateChangeAsUpdate

      public void setReplicateChangeAsUpdate(Boolean replicateChangeAsUpdate)
      Sets whether change operations should be replicated as full update.
      Parameters:
      replicateChangeAsUpdate - true if change should be replicated as update.

    • asGatewaysPolicy

      public GatewaysPolicy asGatewaysPolicy()
      Returns:
      A new GatewaysPolicy instance using the bean's properties.

    • afterPropertiesSet

      public void afterPropertiesSet() throws Exception
      Specified by:
      afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean
      Throws:
      Exception

    • createSpaceComponent

      public SpaceCustomComponent createSpaceComponent()
      Specified by:
      createSpaceComponent in interface SpaceCustomComponentFactoryBean