Package com.lmax.disruptor

Class SimpleBatchRewindStrategy

java.lang.Object

com.lmax.disruptor.SimpleBatchRewindStrategy

All Implemented Interfaces:

BatchRewindStrategy

public class SimpleBatchRewindStrategy
extends Object
implements BatchRewindStrategy

Batch rewind strategy that always rewinds

Constructor Summary

Constructors

Constructor	Description
SimpleBatchRewindStrategy()

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

Constructor Details

SimpleBatchRewindStrategy

public SimpleBatchRewindStrategy()

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