public interface EventProcessorFactory<T>
disruptor.handleEventsWith(handler1).then((ringBuffer, barrierSequences) -> new CustomEventProcessor(ringBuffer, barrierSequences));
Modifier and Type | Method and Description |
---|---|
EventProcessor |
createEventProcessor(RingBuffer<T> ringBuffer,
Sequence[] barrierSequences)
Create a new event processor that gates on
barrierSequences . |
EventProcessor createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
barrierSequences
.barrierSequences
- the sequences to gate onbarrierSequences
before processing events