Package org.apache.storm.messaging.netty

# 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 Summary

  Constructors
  Constructor
  Description
  `MessageBuffer(int mesageBatchSize)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `org.apache.storm.messaging.netty.MessageBatch`
  `add(TaskMessage msg)`
  `org.apache.storm.messaging.netty.MessageBatch`
  `drain()`
  `boolean`
  `isEmpty()`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## 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()