class %External.Messaging.RabbitMQMessage
extends %External.Messaging.Message
RabbitMQ message content and properties
property appId
as %String(MAXLEN=1000);
Message app Id
property clusterId
as %String(MAXLEN=1000);
Cluster Id
property contentEncoding
as %String(MAXLEN=100);
Message content encoding
Only "UTF-8" is supported
property contentType
as %String(MAXLEN=100);
Message content type
property correlationId
as %String(MAXLEN=1000);
Message correlation Id
property deliveryMode
as %Integer(MAXVAL=2,MINVAL=1);
2 indicates persistent, and 1 indicates transient
property encodedContent
as %Stream.GlobalBinary(%JSONINCLUDE="NONE");
The content of the message, stored in a binary stream.
Content should be encoded in the preferred scheme before
writing to the stream, and decoded after reading if necessary.
For example, to encode using UTF-8, then call
$ZCONVERT(text, "O", "UTF8") and write the result to this stream.
property exchange
as %String(MAXLEN=100);
The exchange to which this message should be published
property expiration
as %String(MAXLEN=100);
Message expriation
property headers
as array of %String(MAXLEN="");
This will be converted to a map from String to Object in Java,
and attached to the message as the "headers" property
property messageId
as %String(MAXLEN=1000);
Message Id
property priority
as %Integer;
Message priority
property replyTo
as %String(MAXLEN=100);
Message reply to
property routingKey
as %String(MAXLEN=100);
The routing key to publish with this message
property timestamp
as %TimeStamp;
Message timestamp
property type
as %String(MAXLEN=100);
Message type
property userId
as %String(MAXLEN=1000);
Message user Id
method SetContent(content As %Binary)
Set binary content
method SetEncodedContent(content As %String)
Encode string content as UTF-8