Enum NatsMessage 

pub enum NatsMessage {
    Core(Box<CoreMessage>),
    JetStream(Box<JetStreamMessage>),
}

A NATS delivery. Two flavours: core NATS (no ack) and JetStream (real ack/nack/redelivery).

Both variants are boxed to keep the enum compact; the wrapped async_nats messages are large.

Variants

Core(Box<CoreMessage>)

A core NATS subject delivery. Acknowledgement is not supported.

JetStream(Box<JetStreamMessage>)

A JetStream pull-consumer delivery with full ack support.

Trait Implementations

impl Debug for NatsMessage

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

Formats the value using the given formatter.

impl IncomingMessage for NatsMessage

fn payload(&self) -> &[u8]

Returns the raw payload of the message.

fn headers(&self) -> &Headers

Returns the headers attached to the message.

async fn ack(self) -> Result<(), AckError>

Acknowledges successful processing. Consumes the message handle.

async fn nack(self, requeue: bool) -> Result<(), AckError>

Negatively acknowledges the message. When requeue is true the broker should redeliver according to its own retry policy; when false it should drop or dead-letter the message.