Package org.apache.storm.multilang
Class SpoutMsg
- java.lang.Object
-
- org.apache.storm.multilang.SpoutMsg
-
public class SpoutMsg extends Object
SpoutMsg is an object that represents the data sent from a shell spout to a process that implements a multi-language spout. The SpoutMsg is used to send a "next", "ack" or "fail" message to a spout.Spout messages are objects sent to the ISerializer interface, for serialization according to the wire protocol implemented by the serializer. The SpoutMsg class allows for a decoupling between the serialized representation of the data and the data itself.
-
-
Constructor Summary
Constructors Constructor Description SpoutMsg()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description String
getCommand()
Object
getId()
void
setCommand(String command)
void
setId(Object id)
-