Package com.lmax.disruptor

Interface EventHandler<T>

Type Parameters:

T - event implementation storing the data for sharing during exchange or parallel coordination of an event.

All Known Subinterfaces:

SequenceReportingEventHandler<T>

All Known Implementing Classes:

AggregateEventHandler

public interface EventHandler<T>

Callback interface to be implemented for processing events as they become available in the RingBuffer

See Also:

if you want to handle exceptions propagated out of the handler.

Method Summary

Modifier and Type	Method	Description
void	onEvent(T event, long sequence, boolean endOfBatch)	Called when a publisher has published an event to the RingBuffer

Method Detail

onEvent

void onEvent(T event,
             long sequence,
             boolean endOfBatch)
      throws Exception

Called when a publisher has published an event to the RingBuffer

Parameters:

event - published to the RingBuffer

sequence - of the event being processed

endOfBatch - flag to indicate if this is the last event in a batch from the RingBuffer

Throws:

Exception - if the EventHandler would like the exception handled further up the chain.