Package org.apache.storm.messaging
Class TaskMessage
java.lang.Object
org.apache.storm.messaging.TaskMessage
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeserialize(ByteBuffer packet) byte[]message()inttask()
- 
Constructor Details- 
TaskMessagepublic TaskMessage(int task, byte[] message) 
 
- 
- 
Method Details- 
taskpublic int task()
- 
messagepublic byte[] message()
- 
serialize
- 
deserialize
 
-