Uses of Class
org.apache.storm.messaging.TaskMessage

Packages that use TaskMessage

Package	Description
org.apache.storm.messaging
org.apache.storm.messaging.netty
org.apache.storm.utils

Uses of TaskMessage in org.apache.storm.messaging

Methods in org.apache.storm.messaging with parameters of type TaskMessage

Modifier and Type	Method	Description
protected void	DeserializingConnectionCallback.updateMetrics(int sourceTaskId, TaskMessage message)	Update serialized byte counts for each message.

Method parameters in org.apache.storm.messaging with type arguments of type TaskMessage

Modifier and Type	Method	Description
void	DeserializingConnectionCallback.recv(List<TaskMessage> batch)
void	IConnectionCallback.recv(List<TaskMessage> batch)	A batch of new messages have arrived to be processed.
void	IConnection.send(Iterator<TaskMessage> msgs)	send batch messages.

Uses of TaskMessage in org.apache.storm.messaging.netty

Methods in org.apache.storm.messaging.netty with parameters of type TaskMessage

Modifier and Type	Method	Description
org.apache.storm.messaging.netty.MessageBatch	MessageBuffer.add(TaskMessage msg)

Method parameters in org.apache.storm.messaging.netty with type arguments of type TaskMessage

Modifier and Type	Method	Description
void	Client.send(Iterator<TaskMessage> msgs)	Enqueue task messages to be sent to the remote destination (cf.

Uses of TaskMessage in org.apache.storm.utils

Methods in org.apache.storm.utils with parameters of type TaskMessage

Modifier and Type	Method	Description
void	TransferDrainer.add(TaskMessage taskMsg)