Class 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)