Package org.enanoservices.messagebroker

Class BrokerMessageHeader

java.lang.Object

org.enanoservices.messagebroker.BrokerMessageHeader

public class BrokerMessageHeader
extends java.lang.Object

Broker's message header broker messages include a Header used to identify the message being sent and to be able to identify the deserializer This header needs to be used for all application versions Changing it implies that all the services need to be updated these messages are wrapped in an ActiveMQTextMessage which includes, among others, the following parameters - commandId - responseRequired = false - messageId - originalDestination = null - originalTransactionId = null - producerId - destination = topic://heartbeat - expiration = 1598549182120 (time to live(5000) added to the time stamp - timestamp = 1598549177120 - type = null - priority = 4 - groupID = null

Since:

1.0.0

Author:

Tino Rodríguez

See Also:

BrokerMessageHeader, IBrokerMessageBody

Constructor Summary

Constructors

Constructor	Description
BrokerMessageHeader(java.lang.String msgType, java.lang.String version, java.lang.String origHost, java.lang.String origService, java.lang.String origport, java.lang.String destHost, java.lang.String destService, java.lang.String destPort)

Method Summary

Modifier and Type	Method	Description
static BrokerMessageHeader	deserialize(java.lang.String message)
java.lang.String	getDestHost()
java.lang.String	getDestPort()
java.lang.String	getDestService()
static java.lang.String	getHeartBeat()
static java.lang.String	getKeys()
java.lang.String	getMsgType()
java.lang.String	getOrigHost()
java.lang.String	getOrigPort()
java.lang.String	getOrigService()
static java.lang.String	getRemProv()
static java.lang.String	getRemReq()
static java.lang.String	getRemRes()
long	getTimeSent()
java.lang.String	getVersion()
static boolean	isKeysHeader(java.lang.String msgType)
static boolean	isRemProv(java.lang.String msgType)
static boolean	isRemReq(java.lang.String msgType)
static boolean	isRemRes(java.lang.String msgType)
java.lang.String	serialize()

Methods inherited from class java.lang.Object

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

Constructor Detail

BrokerMessageHeader

public BrokerMessageHeader(java.lang.String msgType,
                           java.lang.String version,
                           java.lang.String origHost,
                           java.lang.String origService,
                           java.lang.String origport,
                           java.lang.String destHost,
                           java.lang.String destService,
                           java.lang.String destPort)

Method Detail

getMsgType

public java.lang.String getMsgType()

getVersion

public java.lang.String getVersion()

getTimeSent

public long getTimeSent()

getOrigHost

public java.lang.String getOrigHost()

getOrigService

public java.lang.String getOrigService()

getOrigPort

public java.lang.String getOrigPort()

getDestHost

public java.lang.String getDestHost()

getDestService

public java.lang.String getDestService()

getDestPort

public java.lang.String getDestPort()

serialize

public java.lang.String serialize()

deserialize

public static BrokerMessageHeader deserialize(java.lang.String message)

isKeysHeader

public static boolean isKeysHeader(java.lang.String msgType)

isRemReq

public static boolean isRemReq(java.lang.String msgType)

isRemRes

public static boolean isRemRes(java.lang.String msgType)

isRemProv

public static boolean isRemProv(java.lang.String msgType)

getHeartBeat

public static java.lang.String getHeartBeat()

getKeys

public static java.lang.String getKeys()

getRemReq

public static java.lang.String getRemReq()

getRemRes

public static java.lang.String getRemRes()

getRemProv

public static java.lang.String getRemProv()