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 and Description
SpoutMsg()

Method Summary

Modifier and Type	Method and Description
String	getCommand()
Object	getId()
void	setCommand(String command)
void	setId(Object id)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)