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 Details

    • createEventProcessor

      EventProcessor createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
      Create a new event processor that gates on barrierSequences.
      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