Package com.lmax.disruptor

Class EventuallyGiveUpBatchRewindStrategy

java.lang.Object

com.lmax.disruptor.EventuallyGiveUpBatchRewindStrategy

All Implemented Interfaces:

BatchRewindStrategy

public class EventuallyGiveUpBatchRewindStrategy
extends Object
implements BatchRewindStrategy

Strategy for handling a rewindableException that will eventually delegate the exception to the ExceptionHandler after a specified number of attempts have been made.

Field Summary

Fields

Modifier and Type	Field	Description
private final long	maxAttempts

Constructor Summary

Constructors

Constructor	Description
EventuallyGiveUpBatchRewindStrategy(long maxAttempts)

Method Summary

Modifier and Type	Method	Description
RewindAction	handleRewindException(RewindableException e, int retriesAttempted)	When a RewindableException is thrown, this will be called.

Methods inherited from class java.lang.Object

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

Field Details

maxAttempts

private final long maxAttempts

Constructor Details

EventuallyGiveUpBatchRewindStrategy

public EventuallyGiveUpBatchRewindStrategy(long maxAttempts)

Parameters:

maxAttempts - numbers of Rewindable exceptions that can be thrown until exception is delegated

Method Details

handleRewindException

public RewindAction handleRewindException(RewindableException e,
 int retriesAttempted)

Description copied from interface: BatchRewindStrategy

When a RewindableException is thrown, this will be called.

Specified by:

handleRewindException in interface BatchRewindStrategy

Parameters:

e - the exception that propagated from the EventHandler.

retriesAttempted - how many attempts there have been for the batch

Returns:

the decision of whether to rewind the batch or throw the exception