Class TaskMessage

java.lang.Object
org.apache.storm.messaging.TaskMessage

public class TaskMessage extends Object
  • 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)