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

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

Modifier and Type	Method and Description
void	IConnectionCallback.recv(List<TaskMessage> batch) A batch of new messages have arrived to be processed
void	DeserializingConnectionCallback.recv(List<TaskMessage> batch)
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 and 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 and 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

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

Modifier and Type	Method and Description
void	TransferDrainer.add(HashMap<Integer,ArrayList<TaskMessage>> taskTupleSetMap)