Class MessageBuffer

java.lang.Object
org.apache.storm.messaging.netty.MessageBuffer

public class MessageBuffer extends Object
Encapsulates the state used for batching up messages.
  • Constructor Details

    • MessageBuffer

      public MessageBuffer(int mesageBatchSize)
  • Method Details

    • add

      public org.apache.storm.messaging.netty.MessageBatch add(TaskMessage msg)
    • isEmpty

      public boolean isEmpty()
    • drain

      public org.apache.storm.messaging.netty.MessageBatch drain()