Interface representing a message received by the MigratoryData cluster.
Public Functions
| Name | |
|---|---|
| String | getSubject() Get the subject of the message. |
| byte[] | getContent() Get the content of the message. |
| Map< String, Object > | getAdditionalInfo() Get additional attributes of the message as key/value pairs. |
Public Functions Documentation
function getSubject
String getSubject()
Get the subject of the message.
Return: the subject of the message.
function getContent
byte[] getContent()
Get the content of the message.
Return: the content of the message.
function getAdditionalInfo
Map< String, Object > getAdditionalInfo()
Get additional attributes of the message as key/value pairs.
The following attributes are currently available:
- seq: the sequence number of the message assigned by the cluster
- epoch: the epoch number of the message assigned by the cluster
- closure: the reference ID of the message assigned by the publisher of the message
- publisherAddress: the Internet address of the publisher of the message
Return: a map with additional attributes of the message.