-
- Type Parameters:
T
- implementation storing the data for sharing during exchange or parallel coordination of an event.
public interface EventProcessorFactory<T>
A factory interface to make it possible to include custom event processors in a chain:disruptor.handleEventsWith(handler1).then((ringBuffer, barrierSequences) -> new CustomEventProcessor(ringBuffer, barrierSequences));
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description EventProcessor
createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
Create a new event processor that gates onbarrierSequences
.
-
-
-
Method Detail
-
createEventProcessor
EventProcessor createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
Create a new event processor that gates onbarrierSequences
.- Parameters:
ringBuffer
- the ring buffer to receive events from.barrierSequences
- the sequences to gate on- Returns:
- a new EventProcessor that gates on
barrierSequences
before processing events
-
-