Interface EventProcessorFactory<T>

  • 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 Detail

      • 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