T
- event implementation storing the data for sharing during exchange or parallel coordination of an event.SequenceReportingEventHandler<T>
AggregateEventHandler
public interface EventHandler<T>
RingBuffer
Modifier and Type | Method | Description |
---|---|---|
void |
onEvent(T event,
long sequence,
boolean endOfBatch) |
Called when a publisher has published an event to the
RingBuffer |
void onEvent(T event, long sequence, boolean endOfBatch) throws Exception
RingBuffer
event
- published to the RingBuffer
sequence
- of the event being processedendOfBatch
- flag to indicate if this is the last event in a batch from the RingBuffer
Exception
- if the EventHandler would like the exception handled further up the chain.Copyright © 2019. All rights reserved.