backtype.storm.messaging.netty

Class MessageBuffer

java.lang.Object

backtype.storm.messaging.netty.MessageBuffer

public class MessageBuffer
extends Object

Encapsulates the state used for batching up messages.

Constructor Summary

Constructors

Constructor and Description
MessageBuffer(int mesageBatchSize)

Method Summary

Modifier and Type	Method and Description
backtype.storm.messaging.netty.MessageBatch	add(TaskMessage msg)
backtype.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 Detail

MessageBuffer

public MessageBuffer(int mesageBatchSize)

Method Detail

add

public backtype.storm.messaging.netty.MessageBatch add(TaskMessage msg)

isEmpty

public boolean isEmpty()

drain

public backtype.storm.messaging.netty.MessageBatch drain()