Struct JetStreamMessage 

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

A typed message from a JetStream consumer.

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.

Implementations

impl<T> JetStreamMessage<T>

pub async fn ack(&self) -> Result<()>

Acknowledge the message.

pub async fn double_ack(&self) -> Result<()>

Acknowledge the message with double ack.

pub async fn nak(&self) -> Result<()>

Negatively acknowledge the message.

pub async fn nak_with_delay(&self, delay: Duration) -> Result<()>

Negatively acknowledge with a delay before redelivery.

pub async fn in_progress(&self) -> Result<()>

Mark the message as in progress.

pub async fn term(&self) -> Result<()>

Terminate the message (will not be redelivered).

pub fn raw(&self) -> &Message

Get the raw underlying JetStream message.

Trait Implementations

impl<T: Debug> Debug for JetStreamMessage<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.