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 SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.storm.messaging.netty.MessageBatchadd(TaskMessage msg) org.apache.storm.messaging.netty.MessageBatchdrain()booleanisEmpty()
- 
Constructor Details- 
MessageBufferpublic MessageBuffer(int mesageBatchSize) 
 
- 
- 
Method Details- 
add
- 
isEmptypublic boolean isEmpty()
- 
drainpublic org.apache.storm.messaging.netty.MessageBatch drain()
 
-