Type Alias QueueMessage 

pub type QueueMessage<T> = JetStreamMessage<T>;

A message from a work queue or interest queue.

This is an alias for JetStreamMessage for convenience.

Aliased Type

pub struct QueueMessage<T> {
    pub payload: T,
    pub subject: String,
    pub stream_sequence: u64,
    pub consumer_sequence: u64,
    pub reply: Option<String>,
    /* private fields */
}

Fields

payload: T

The decoded message payload.

subject: String

The subject the message was published to.

stream_sequence: u64

The stream sequence number.

consumer_sequence: u64

The consumer sequence number.

reply: Option<String>

The reply subject for request-reply patterns.