The message's data
Any headers associated with the message
The delivery info for the message
True if the message was redelivered
The sequence number for the message
The subject on which the message was published
!! this is an experimental feature - and could be removed
next() combines ack() and pull(), requires the subject for a subscription processing to process a message is provided (can be the same) however, because the ability to specify how long to keep the request open can be specified, this functionality doesn't work well with iterators, as an error (408s) are expected and needed to re-trigger a pull in case there was a timeout. In an iterator, the error will close the iterator, requiring a subscription to be reset.
Optional
ro: Partial<PullOptions>Indicate to the JetStream server that processing of the message failed and that the message should not be sent to the consumer again.
Optional
reason: stringis a string describing why the message was termed. Note
that reason
is only available on servers 2.11.0 or better.
Generated using TypeDoc
Represents a message stored in JetStream