Package org.apache.storm.messaging.netty
Class MessageBuffer
java.lang.Object
org.apache.storm.messaging.netty.MessageBuffer
Encapsulates the state used for batching up messages.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.storm.messaging.netty.MessageBatch
add
(TaskMessage msg) org.apache.storm.messaging.netty.MessageBatch
drain()
boolean
isEmpty()
-
Constructor Details
-
MessageBuffer
public MessageBuffer(int mesageBatchSize)
-
-
Method Details
-
add
-
isEmpty
public boolean isEmpty() -
drain
public org.apache.storm.messaging.netty.MessageBatch drain()
-