Class CommandHelper.LogAggregatorMessage

java.lang.Object
com.illumon.iris.db.v2.logaggregator.CommandHelper.LogAggregatorMessage
Enclosing class:
CommandHelper

public static class CommandHelper.LogAggregatorMessage extends Object
Combine together a QueueCommandId, a message from the buffer pool, and a possible action to call. This is a transition class; it's likely it, and the queue, can be redesigned.
  • Method Details

    • getCommand

      public CommandHelper.QueueCommandId getCommand()
    • getMessage

      public com.fishlib.io.sched.Message getMessage()
    • getBuffer

      public ByteBuffer getBuffer()
    • finished

      public void finished()