Package org.openspaces.core.gateway

Class SinkErrorHandlingFactoryBean

java.lang.Object
org.openspaces.core.gateway.SinkErrorHandlingFactoryBean
public class SinkErrorHandlingFactoryBean extends Object
A factory bean used for configuring the Sink component error handling configuration.
Since:
8.0.3
Author:
idan

  • Constructor Details

    • SinkErrorHandlingFactoryBean

      public SinkErrorHandlingFactoryBean()

  • Method Details

    • setMaximumRetriesOnTransactionLock

      public void setMaximumRetriesOnTransactionLock(Integer maximumRetriesOnTransactionLock)
      Sets the maximum retries number of a failed operation due to transaction lock.
      Parameters:
      maximumRetriesOnTransactionLock - Maximum retries number.

    • getMaximumRetriesOnTransactionLock

      public Integer getMaximumRetriesOnTransactionLock()
      Gets the maximum retries number defined for a failed operation which failed due to transaction lock.
      Returns:
      Maximum retries count.

    • setTransactionLockRetryInterval

      public void setTransactionLockRetryInterval(Integer transactionLockRetryInterval)
      Sets the time interval between failed operations retry attempts.
      Parameters:
      transactionLockRetryInterval - Time interval between retry attempts.

    • getTransactionLockRetryInterval

      public Integer getTransactionLockRetryInterval()
      Gets the defined time interval between failed operations retry attempts.
      Returns:
      Time interval between attempts.

    • setConflictResolver

      public void setConflictResolver(ConflictResolver conflictResolver)
      Sets the ConflictResolver implementation to be used with the Sink component.
      Parameters:
      conflictResolver - The ConflictResolver implementation.

    • getConflictResolver

      public ConflictResolver getConflictResolver()
      Gets the ConflictResolver implementation which is used with the Sink component.
      Returns:
      The ConflictResolver implementation.

    • copyToSinkConfiguration

      protected void copyToSinkConfiguration(LocalClusterReplicationSinkConfig config)