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
barrierSequences
before processing events
-