Uses of Class
org.apache.storm.messaging.TaskMessage
Package
Description
-
Uses of TaskMessage in org.apache.storm.messaging
Modifier and TypeMethodDescriptionprotected void
DeserializingConnectionCallback.updateMetrics
(int sourceTaskId, TaskMessage message) Update serialized byte counts for each message.Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionorg.apache.storm.messaging.netty.MessageBatch
MessageBuffer.add
(TaskMessage msg) Modifier and TypeMethodDescriptionvoid
Client.send
(Iterator<TaskMessage> msgs) Enqueue task messages to be sent to the remote destination (cf. -
Uses of TaskMessage in org.apache.storm.utils