org.apache.tephra

Class RetryOnConflictStrategy

java.lang.Object

org.apache.tephra.RetryOnConflictStrategy

All Implemented Interfaces:

RetryStrategy

public class RetryOnConflictStrategy
extends Object
implements RetryStrategy

Retries transaction execution when transaction fails with TransactionConflictException.

Constructor Summary

Constructors

Constructor and Description
RetryOnConflictStrategy(int maxRetries, long retryDelay)

Method Summary

Modifier and Type	Method and Description
long	nextRetry(TransactionFailureException reason, int failureCount) Returns the number of milliseconds to wait before retrying the operation.

Methods inherited from class java.lang.Object

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

Constructor Detail

RetryOnConflictStrategy

public RetryOnConflictStrategy(int maxRetries,
                               long retryDelay)

Method Detail

nextRetry

public long nextRetry(TransactionFailureException reason,
                      int failureCount)

Description copied from interface: RetryStrategy

Returns the number of milliseconds to wait before retrying the operation.

Specified by:

nextRetry in interface RetryStrategy

Parameters:

reason - Reason for transaction failure.

failureCount - Number of times that the request has been failed.

Returns:

Number of milliseconds to wait before retrying the operation. Returning 0 means retry it immediately, while negative means abort the operation.