Class LocalClusterReplicationSinkConfig

java.lang.Object
com.gigaspaces.internal.cluster.node.impl.gateway.delegator.ReplicationGatewayComponentConfig
com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationSinkConfig

public class LocalClusterReplicationSinkConfig extends ReplicationGatewayComponentConfig
  • Constructor Details

    • LocalClusterReplicationSinkConfig

      public LocalClusterReplicationSinkConfig(String mySiteName)
  • Method Details

    • setLocalClusterSpaceUrl

      public void setLocalClusterSpaceUrl(String localClusterSpaceUrl)
    • getLocalClusterSpaceUrl

      public String getLocalClusterSpaceUrl()
    • setSiteNames

      public void setSiteNames(String[] siteNames)
    • getSiteNames

      public String[] getSiteNames()
    • getConflictResolver

      public ConflictResolver getConflictResolver()
    • setConflictResolver

      public void setConflictResolver(ConflictResolver conflictResolver)
    • getMaximumRetriesOnTransactionLock

      public int getMaximumRetriesOnTransactionLock()
    • setMaximumRetriesOnTransactionLock

      public void setMaximumRetriesOnTransactionLock(int maximumRetriesOnTransactionLock)
    • setRequiresBootstrap

      public void setRequiresBootstrap(boolean requiresBootstrap)
    • isRequiresBootstrap

      public boolean isRequiresBootstrap()
    • getTransactionLockRetryInterval

      public int getTransactionLockRetryInterval()
    • setTransactionLockRetryInterval

      public void setTransactionLockRetryInterval(int transactionLockRetryInterval)
    • setTransactionTimeout

      public void setTransactionTimeout(long transactionTimeout)
    • getTransactionTimeout

      public long getTransactionTimeout()
    • getTransactionProcessingParameters

      public DistributedTransactionProcessingConfiguration getTransactionProcessingParameters()
    • setSyncEndpointInterceptor

      public void setSyncEndpointInterceptor(SynchronizationEndpointInterceptor interceptor)
    • getSyncEndpointInterceptor

      public SynchronizationEndpointInterceptor getSyncEndpointInterceptor()
    • getCredentialsProvider

      public CredentialsProvider getCredentialsProvider()
    • setCredentialsProvider

      public void setCredentialsProvider(CredentialsProvider credentialsProvider)
    • clearCredentialsProvider

      public void clearCredentialsProvider()
    • dumpState

      public String dumpState()