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