Package org.graylog2.shared.buffers

Interface WorkHandler<T>

All Known Implementing Classes:
OutputBufferProcessor, ProcessBufferProcessor, RawMessageEncoderHandler
public interface WorkHandler<T>
Based on the original WorkHandler interface. This was previously used for handlers which are part of a worker pool but the functionality was removed from the disruptor library. We are keeping the interface but workers implementing it won't be able to use the batching semantics that an EventHandler provides.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onEvent(T event)
     
    default void
    onShutdown()
    Called once just before the thread is shutdown.
    default void
    onStart()
    Called once on thread start before first event is available.

  • Method Details

    • onEvent

      void onEvent(T event) throws Exception
      Throws:
      Exception

    • onStart

      default void onStart()
      Called once on thread start before first event is available.

    • onShutdown

      default void onShutdown()

      Called once just before the thread is shutdown.

      Sequence event processing will already have stopped before this method is called. No events will be processed after this message.