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 Details

    • SpoutMsg

      public SpoutMsg()

  • Method Details

    • getCommand

      public String getCommand()

    • setCommand

      public void setCommand(String command)

    • getId

      public Object getId()

    • setId

      public void setId(Object id)