Returns the acknowledgement type for the given command. Multiple ack types are comma-delimited.
The acknowledgement message type.
Returns the specified number of messages that are batched together when returning a query result.
The batch size value.
Returns a client-originated identifier used to mark a location in journaled messages.
The bookmark value.
Returns the client name value. Used to identify a client. Useful for publishers that wish to identify the source of a publish, client status messages and for client heartbeats.
The client name value.
Returns the command name, e.g. 'publish', 'sow_and_subscribe', which is one of the following:
Returns the command name.
The command name value.
Returns the command id.
The command id value.
Returns the correlation id: opaque token set by an application and returned with the message. Must be
base64
encoded characters only.
The correlationId value.
Returns the Message expiration value (in seconds).
The Message expiration value.
Returns the content filter value.
The content filter value.
Returns the Group Sequence Number for each batch message of a SOW response.
For messages from a queue, returns the time at which the lease expires.
As a part of the acknowledgement to a SOW query, returns the number of matches.
Sent with XML formatted message data to indicate the number of bytes used by the message body.
Returns a comma-delimited list of options on a specific command.
The options value.
Returns the SOW topic key(s) by which to order SOW query.
The orderBy value.
Returns the query id.
The query id.
Returns the failure message that appears when an acknowledgement returns a status of failure.
The failure reason value.
Returns the number of records deleted from the SOW with a sow_delete
command.
Used in conjunction with the stats acknowledgement.
The recordsDeleted value.
Returns the number of records inserted into the SOW. Used in conjunction with the stats acknowledgement.
The recordsInserted value.
Returns number of records in the store. The value is returned in the acknowledgement to an SOW query.
The recordsReturned value.
Returns the number of records updated in the SOW. Used in conjunction with the stats acknowledgement.
The recordsUpdated value.
Returns an integer that corresponds to the publish message sequence number. For more information see the Replication section in the User Guide.
The sequenceId value.
Returns the sow key value. A SOW key will accompany each message returned in an SOW batch. A SowKey may also be added to messages coming in on a subscription when the published message matches a record in the SOW.
Format:
OR
The sow key value.
Returns the sowKeys as a comma-delimited value.
The sowKeys value.
Returns the client status when client is monitored for heartbeats.
The client status value.
Returns the subscription id.
The subscription id.
Returns a comma-separated list of SubIds sent from AMPS engine to identify which client subscriptions match a
given publish
message.
The subIds (comma-delimited) value.
Returns the message timestamp set by the server in a ISO-8601 date-time format.
The timestamp value.
Returns the number of records to return. Note: If TopN is not equally divisible by the batch size, then more records will be returned so that the total number of records is equally divisible by the batch size setting.
The top N value.
Returns the topic value.
The topic value.
Returns the number of topic matches for the SOW query. Sent in stats
acknowledgement message.
The topicMatches value.
Returns the transmission time value.
The transmission time value.
Returns the user id used to identify the user of a command.
The userId value.
This is a class that encapsulates a message header. The message header is exposed via
message.header
field of the Message class:const messageHandler = message => { if (message.header.command() === 'sow') { console.log(message.header.groupSequenceNumber()); console.log(message.data); } };
Not all messages populate all headers. The Command Reference provides detailed description of the headers returned on specific messages and what they contain.