T
- event implementation storing the data for sharing during exchange or parallel coordination of an event.public interface EventHandler<T>
RingBuffer
Modifier and Type | Method and 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
. The BatchEventProcessor
will
read messages from the RingBuffer
in batches, where a batch is all of the events available to be
processed without having to wait for any new event to arrive. This can be useful for event handlers that need
to do slower operations like I/O as they can group together the data from multiple events into a single
operation. Implementations should ensure that the operation is always performed when endOfBatch is true as
the time between that message an the next one is inderminate.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 © 2022. All rights reserved.