Uses of Class
org.apache.storm.messaging.TaskMessage
Packages that use TaskMessage
Package
Description
- 
Uses of TaskMessage in org.apache.storm.messagingMethods in org.apache.storm.messaging with parameters of type TaskMessageModifier and TypeMethodDescriptionprotected voidDeserializingConnectionCallback.updateMetrics(int sourceTaskId, TaskMessage message) Update serialized byte counts for each message.Method parameters in org.apache.storm.messaging with type arguments of type TaskMessageModifier and TypeMethodDescriptionvoidDeserializingConnectionCallback.recv(List<TaskMessage> batch) voidIConnectionCallback.recv(List<TaskMessage> batch) A batch of new messages have arrived to be processed.voidIConnection.send(Iterator<TaskMessage> msgs) send batch messages.
- 
Uses of TaskMessage in org.apache.storm.messaging.nettyMethods in org.apache.storm.messaging.netty with parameters of type TaskMessageModifier and TypeMethodDescriptionorg.apache.storm.messaging.netty.MessageBatchMessageBuffer.add(TaskMessage msg) Method parameters in org.apache.storm.messaging.netty with type arguments of type TaskMessageModifier and TypeMethodDescriptionvoidClient.send(Iterator<TaskMessage> msgs) Enqueue task messages to be sent to the remote destination (cf.
- 
Uses of TaskMessage in org.apache.storm.utilsMethods in org.apache.storm.utils with parameters of type TaskMessage