NanosecondPauseBatchRewindStrategy

java.lang.Object

com.lmax.disruptor.NanosecondPauseBatchRewindStrategy

All Implemented Interfaces:: BatchRewindStrategy

public class NanosecondPauseBatchRewindStrategy extends Object implements BatchRewindStrategy

Strategy for handling a rewindableException that will pause for a specified amount of nanos.

Field Summary

Fields

Modifier and Type

Field

Description

private final long

nanoSecondPauseTime
Constructor Summary

Constructors

Constructor

Description

NanosecondPauseBatchRewindStrategy(long nanoSecondPauseTime)

Strategy for handling a rewindableException that will pause for a specified amount of nanos.
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
- nanoSecondPauseTime
  
  private final long nanoSecondPauseTime
Constructor Details
- NanosecondPauseBatchRewindStrategy
  
  public NanosecondPauseBatchRewindStrategy(long nanoSecondPauseTime)
  
  Strategy for handling a rewindableException that will pause for a specified amount of nanos.
  
  Parameters:
  
  nanoSecondPauseTime - Amount of nanos to pause for when a rewindable exception is thrown
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