Package org.eso.ias.command
Class CommandMessage
java.lang.Object
org.eso.ias.command.CommandMessage
The java POJO representing a command to be published in the command kafka topic
This POJO is serialized into a JSON string to be published in the
kafka topic
-
Field Summary
Modifier and TypeFieldDescriptionstatic final String
The address to send a message to all the IAS tools -
Constructor Summary
ConstructorDescriptionEmpty constructorCommandMessage
(String senderFullRunningId, String destId, CommandType command, long id, List<String> params, long timestamp, Map<String, String> properties) Constructor -
Method Summary
Modifier and TypeMethodDescriptionboolean
long
getId()
long
int
hashCode()
void
setCommand
(CommandType command) void
void
setId
(long id) void
void
setProperties
(Map<String, String> properties) void
setSenderFullRunningId
(String senderFullRunningId) void
setTimestamp
(String isoTStamp) Set the timestamp to the passed ISO 8601 timestampvoid
setTimestampMillis
(long timestamp) toString()
-
Field Details
-
BROADCAST_ADDRESS
The address to send a message to all the IAS tools- See Also:
-
-
Constructor Details
-
CommandMessage
public CommandMessage()Empty constructor -
CommandMessage
public CommandMessage(String senderFullRunningId, String destId, CommandType command, long id, List<String> params, long timestamp, Map<String, String> properties) Constructor- Parameters:
senderFullRunningId
- The full running ID of the sender of the commanddestId
- The identifier of the receivercommand
- The command to executeid
- The unique identifier (in the context of the sender) of the commandparams
- The parameters of the command, if anytimestamp
- he timestamp when the command has been publishedproperties
- Additional properties, if any
-
-
Method Details
-
getSenderFullRunningId
-
setSenderFullRunningId
-
getDestId
-
setDestId
-
getCommand
-
setCommand
-
getId
public long getId() -
setId
public void setId(long id) -
getParams
-
setParams
-
getTimestamp
-
getTimestampMillis
public long getTimestampMillis() -
setTimestampMillis
public void setTimestampMillis(long timestamp) -
setTimestamp
Set the timestamp to the passed ISO 8601 timestamp -
getProperties
-
setProperties
-
equals
-
hashCode
public int hashCode() -
toString
-