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 Detail

      • SpoutMsg

        public SpoutMsg()
    • Method Detail

      • getCommand

        public String getCommand()
      • setCommand

        public void setCommand​(String command)
      • getId

        public Object getId()
      • setId

        public void setId​(Object id)