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