Package org.apache.storm.messaging

Class TaskMessage

java.lang.Object

org.apache.storm.messaging.TaskMessage

public class TaskMessage
extends Object

Constructor Summary

Constructors

Constructor	Description
TaskMessage(int task, byte[] message)

Method Summary

Modifier and Type	Method	Description
void	deserialize(ByteBuffer packet)
byte[]	message()
ByteBuffer	serialize()
int	task()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TaskMessage

public TaskMessage(int task,
 byte[] message)

Method Details

task

public int task()

message

public byte[] message()

serialize

public ByteBuffer serialize()

deserialize

public void deserialize(ByteBuffer packet)