MigratoryDataPresenceListener::Message
Interface to handle messages accepted by the 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 message subject
function getContent
byte[] getContent()
Get the content of the message.
Return: the message content
function getAdditionalInfo
Map< String, Object > getAdditionalInfo()
Get additional attributes of the message as key/value pairs.
Return: a map with additional message attributes
The following attributes are currently available:
- seq - the sequence number assigned by the cluster member which is the coordinator of the message subject
- epoch - the epoch number assigned by the cluster member which is the coordinator of the message subject
- closure - the closure of the message assigned by the publisher of the message
- publisherAddress - the Internet address of the publisher of the message
Updated on 9 November 2020 at 21:01:04 EET