MigratoryDataPublishListener::PublishEvent

Provide information about the received message.

Inherits from Event

Public Functions

Name
String getSubject()
Provides the message subject.
byte[] getContent()
Provides the message content.
int getSeqNo()
Provides the sequence number of the message.
int getEpochNo()
Provides the epoch number of the message.
String getStatus()
Provides the publication status of the message.
Map< String, Object > getAdditionalInfo()
Get additional attributes as key/value pairs.

Public Functions Documentation

function getSubject

String getSubject()

Provides the message subject.

Return: the message subject

function getContent

byte[] getContent()

Provides the message content.

Return: the message content

function getSeqNo

int getSeqNo()

Provides the sequence number of the message.

Return: the sequence number of the message

function getEpochNo

int getEpochNo()

Provides the epoch number of the message.

Return: the epoch number of the message

function getStatus

String getStatus()

Provides the publication status of the message.

Return: the publication status of the message received by the cluster

The typical status values are as follows:

  • OK - the message received from the publisher has been accepted by the cluster and will be published to all subscribers of the message subject
  • DENY - the message received from the publisher has not been accepted by the cluster because the publisher is not authorized to publish on the message subject
  • FAILED - the message received from the publisher has not been accepted by the cluster due to a failure; the cluster notifies the publisher about this failure, so that the publisher has the option to republish the message

function getAdditionalInfo

Map< String, Object > getAdditionalInfo()

Get additional attributes as key/value pairs.

Return: a map with additional attributes

No additional attributes are currently available.