Struct JsMessage 

pub struct JsMessage {
    pub subject: String,
    pub payload: Vec<u8>,
    pub sequence: u64,
    pub delivered: u32,
    /* private fields */
}

A message from JetStream with ack capabilities.

Fields

subject: String

Original NATS message.

payload: Vec<u8>

Message payload.

sequence: u64

Stream sequence number.

delivered: u32

Delivery count.

Implementations

impl JsMessage

pub fn is_acked(&self) -> bool

Check if the message has been acknowledged.

impl JsMessage

pub async fn ack(&self, client: &mut NatsClient, cx: &Cx) -> Result<(), JsError>

Acknowledge the message (marks as processed).

pub async fn nack( &self, client: &mut NatsClient, cx: &Cx, ) -> Result<(), JsError>

Negative acknowledge (request redelivery).

pub async fn in_progress( &self, client: &mut NatsClient, cx: &Cx, ) -> Result<(), JsError>

Acknowledge in progress (extend ack deadline).

pub async fn term( &self, client: &mut NatsClient, cx: &Cx, ) -> Result<(), JsError>

Terminate processing (do not redeliver).

Trait Implementations

impl Debug for JsMessage

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

Formats the value using the given formatter.

impl Drop for JsMessage

fn drop(&mut self)

Executes the destructor for this type.