Interface EventProcessor

  • All Superinterfaces:
    java.lang.Runnable
    All Known Implementing Classes:
    BatchEventProcessor, NoOpEventProcessor, WorkProcessor

    public interface EventProcessor
    extends java.lang.Runnable
    EventProcessors waitFor events to become available for consumption from the RingBuffer

    An EventProcessor will generally be associated with a Thread for execution.

    • Method Detail

      • halt

        void halt()
        Signal that this EventProcessor should stop when it has finished consuming at the next clean break. It will call SequenceBarrier.alert() to notify the thread to check status.
      • isRunning

        boolean isRunning()