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>, EventHandlerBase<T>, EventHandlerIdentity

public interface SequenceReportingEventHandler<T>
extends EventHandler<T>

Used by the BatchEventProcessor to set a callback allowing the EventHandler to notify when it has finished consuming an event if this happens after the EventHandler.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

Modifier and Type	Method	Description
void	setSequenceCallback(Sequence sequenceCallback)	Call by the BatchEventProcessor to setup the callback.

Methods inherited from interface com.lmax.disruptor.EventHandler

onEvent

Methods inherited from interface com.lmax.disruptor.EventHandlerBase

onBatchStart, onShutdown, onStart, onTimeout

Method Details

setSequenceCallback

void setSequenceCallback(Sequence sequenceCallback)

Call by the BatchEventProcessor to setup the callback.

Specified by:

setSequenceCallback in interface EventHandler<T>

Parameters:

sequenceCallback - callback on which to notify the BatchEventProcessor that the sequence has progressed.