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 Summary

SinkErrorHandlingFactoryBean()

Method Summary

protected void	copyToSinkConfiguration(com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationSinkConfig config)
ConflictResolver	getConflictResolver() Gets the ConflictResolver implementation which is used with the Sink component.
Integer	getMaximumRetriesOnTransactionLock() Gets the maximum retries number defined for a failed operation which failed due to transaction lock.
Integer	getTransactionLockRetryInterval() Gets the defined time interval between failed operations retry attempts.
void	setConflictResolver(ConflictResolver conflictResolver) Sets the ConflictResolver implementation to be used with the Sink component.
void	setMaximumRetriesOnTransactionLock(Integer maximumRetriesOnTransactionLock) Sets the maximum retries number of a failed operation due to transaction lock.
void	setTransactionLockRetryInterval(Integer transactionLockRetryInterval) Sets the time interval between failed operations retry attempts.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SinkErrorHandlingFactoryBean

public SinkErrorHandlingFactoryBean()

Method Detail

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(com.gigaspaces.internal.cluster.node.impl.gateway.sink.LocalClusterReplicationSinkConfig config)