- java.lang.Object
-
- com.lmax.disruptor.SimpleBatchRewindStrategy
-
- All Implemented Interfaces:
BatchRewindStrategy
public class SimpleBatchRewindStrategy extends java.lang.Object implements BatchRewindStrategy
Batch rewind strategy that always rewinds
-
-
Constructor Summary
Constructors Constructor Description SimpleBatchRewindStrategy()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description RewindAction
handleRewindException(RewindableException e, int retriesAttempted)
When aRewindableException
is thrown, this will be called.
-
-
-
Method Detail
-
handleRewindException
public RewindAction handleRewindException(RewindableException e, int retriesAttempted)
Description copied from interface:BatchRewindStrategy
When aRewindableException
is thrown, this will be called.- Specified by:
handleRewindException
in interfaceBatchRewindStrategy
- Parameters:
e
- the exception that propagated from theEventHandler
.retriesAttempted
- how many attempts there have been for the batch- Returns:
- the decision of whether to rewind the batch or throw the exception
-
-