Package com.lmax.disruptor
Interface SequenceReportingEventHandler<T>
-
- Type Parameters:
T- event implementation storing the data for sharing during exchange or parallel coordination of an event.
- All Superinterfaces:
EventHandler<T>
public interface SequenceReportingEventHandler<T> extends EventHandler<T>
Used by theBatchEventProcessorto set a callback allowing theEventHandlerto notify when it has finished consuming an event if this happens after theEventHandler.onEvent(Object, long, boolean)call.Typically this would be used when the handler is performing some sort of batching operation such as writing to an IO device; after the operation has completed, the implementation should call
Sequence.set(long)to update the sequence and allow other processes that are dependent on this handler to progress.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidsetSequenceCallback(Sequence sequenceCallback)Call by theBatchEventProcessorto setup the callback.-
Methods inherited from interface com.lmax.disruptor.EventHandler
onEvent
-
-
-
-
Method Detail
-
setSequenceCallback
void setSequenceCallback(Sequence sequenceCallback)
Call by theBatchEventProcessorto setup the callback.- Parameters:
sequenceCallback- callback on which to notify theBatchEventProcessorthat the sequence has progressed.
-
-