Package org.eso.ias.command

Class ReplyMessage

java.lang.Object

org.eso.ias.command.ReplyMessage

public class ReplyMessage
extends Object

The java POJO to send replies over the kafka topic. This POJO is serialized into a JSON string to be published in the kafka topic

Author:

acaproni

Constructor Summary

Constructors

Constructor	Description
ReplyMessage()	Empty constructor
ReplyMessage(String senderFullRunningId, String destFullRunningId, long id, CommandType command, CommandExitStatus exitStatus, long receptionTStamp, long processedTStamp, Map<String,String> properties)	Constructor

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
CommandType	getCommand()
String	getDestFullRunningId()
CommandExitStatus	getExitStatus()
long	getId()
String	getProcessedTStamp()
long	getProcessedTStampMillis()
Map<String,String>	getProperties()
String	getReceptionTStamp()
long	getReceptionTStampMillis()
String	getSenderFullRunningId()
int	hashCode()
void	setCommand(CommandType command)
void	setDestFullRunningId(String destFullRunningId)
void	setExitStatus(CommandExitStatus exitStatus)
void	setId(long id)
void	setProcessedTStamp(String processedTStamp)
void	setProcessedTStampMillis(long processedTStamp)
void	setProperties(Map<String,String> properties)
void	setReceptionTStamp(String receptionTStamp)
void	setReceptionTStampMillis(long receptionTStamp)
void	setSenderFullRunningId(String senderFullRunningId)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ReplyMessage

public ReplyMessage()

Empty constructor

ReplyMessage

public ReplyMessage(String senderFullRunningId,
 String destFullRunningId,
 long id,
 CommandType command,
 CommandExitStatus exitStatus,
 long receptionTStamp,
 long processedTStamp,
 Map<String,String> properties)

Constructor

Parameters:

senderFullRunningId - The full running ID of the sender of the reply

destFullRunningId - The full running ID of the receiver of the command

id - The unique identifier (in the context of the sender) of the command

command - The command just executed

exitStatus - The exit status of the command

receptionTStamp - The point in time when the command has been received from the kafka topic

processedTStamp - The point in time when the execution of the command terminated

properties - Additional properties, if any

Method Details

getSenderFullRunningId

public String getSenderFullRunningId()

setSenderFullRunningId

public void setSenderFullRunningId(String senderFullRunningId)

getDestFullRunningId

public String getDestFullRunningId()

setDestFullRunningId

public void setDestFullRunningId(String destFullRunningId)

getId

public long getId()

setId

public void setId(long id)

getCommand

public CommandType getCommand()

setCommand

public void setCommand(CommandType command)

getExitStatus

public CommandExitStatus getExitStatus()

setExitStatus

public void setExitStatus(CommandExitStatus exitStatus)

getReceptionTStamp

public String getReceptionTStamp()

getReceptionTStampMillis

public long getReceptionTStampMillis()

setReceptionTStamp

public void setReceptionTStamp(String receptionTStamp)

setReceptionTStampMillis

public void setReceptionTStampMillis(long receptionTStamp)

getProcessedTStamp

public String getProcessedTStamp()

getProcessedTStampMillis

public long getProcessedTStampMillis()

setProcessedTStamp

public void setProcessedTStamp(String processedTStamp)

setProcessedTStampMillis

public void setProcessedTStampMillis(long processedTStamp)

getProperties

public Map<String,String> getProperties()

setProperties

public void setProperties(Map<String,String> properties)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object