QueueMessage

Type Alias QueueMessage 

Source
pub type QueueMessage<T> = JetStreamMessage<T>;
Expand description

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,
    /* 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.