Interface EventHandler<T>

    • Method Detail

      • onEvent

        void onEvent​(T event,
                     long sequence,
                     boolean endOfBatch)
              throws java.lang.Exception
        Called when a publisher has published an event to the RingBuffer. The BatchEventProcessor will read messages from the RingBuffer in batches, where a batch is all of the events available to be processed without having to wait for any new event to arrive. This can be useful for event handlers that need to do slower operations like I/O as they can group together the data from multiple events into a single operation. Implementations should ensure that the operation is always performed when endOfBatch is true as the time between that message an the next one is inderminate.
        Parameters:
        event - published to the RingBuffer
        sequence - of the event being processed
        endOfBatch - flag to indicate if this is the last event in a batch from the RingBuffer
        Throws:
        java.lang.Exception - if the EventHandler would like the exception handled further up the chain.