@Override
  public void onEvent(RingBufferEnvelope event, long sequence, boolean endOfBatch) {
    final NamedQueuePayload namedQueuePayload = event.getPayload();
    // consume ringbuffer payload based on event type
    namedQueueServices.get(namedQueuePayload.getNamedQueueEvent())
      .consumeEventFromDisruptor(namedQueuePayload);
  }
Called when a publisher has published an event to the {@link RingBuffer}. This is generic
consumer of disruptor ringbuffer and for each new namedQueue that we add, we should also
provide specific consumer logic here.
@param event      published to the {@link RingBuffer}
@param sequence   of the event being processed
@param endOfBatch flag to indicate if this is the last event in a batch from the
                  {@link RingBuffer}
hbase-server/src/main/java/org/apache/hadoop/hbase/namequeues/LogEventHandler.java