Package com.lmax.disruptor.dsl
Interface EventProcessorFactory<T>
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
Modifier and TypeMethodDescriptioncreateEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences) Create a new event processor that gates onbarrierSequences.
-
Method Details
-
createEventProcessor
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
barrierSequencesbefore processing events
-