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 theRingBuffer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
onEvent(T event, long sequence, boolean endOfBatch)
Called when a publisher has published an event to theRingBuffer
-
-
-
Method Detail
-
onEvent
void onEvent(T event, long sequence, boolean endOfBatch) throws Exception
Called when a publisher has published an event to theRingBuffer
- Parameters:
event
- published to theRingBuffer
sequence
- of the event being processedendOfBatch
- flag to indicate if this is the last event in a batch from theRingBuffer
- Throws:
Exception
- if the EventHandler would like the exception handled further up the chain.
-
-