Struct PulsarMessage 

pub struct PulsarMessage { /* private fields */ }

A message delivered by a PulsarSubscriber.

ack acknowledges; nack(requeue = true) asks the broker to redeliver, which is what drives the delivery count towards the subscription’s dead-letter policy. nack(requeue = false) acknowledges: Pulsar has no terminal reject verb - poison routing belongs to the dead-letter policy, reached by repeated redelivery. The client queues acknowledgements asynchronously, so Ok means “queued”, not “broker confirmed”.

Implementations

impl PulsarMessage

pub fn topic(&self) -> &str

The fully resolved topic this message arrived on (with its partition suffix when the topic is partitioned).

Trait Implementations

impl Debug for PulsarMessage

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

Formats the value using the given formatter.

impl IncomingMessage for PulsarMessage

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.

fn partition_key(&self) -> Option<&[u8]>

Returns the routing key the broker partitioned this message by, or None when the message carries no key.

fn supports_nack_after(&self) -> bool

Reports whether this transport can honor nack_after natively.

fn nack_after( self, delay: Duration, ) -> impl Future<Output = Result<(), AckError>> + Send

where Self: Sized,

Negatively acknowledges the message, asking the broker to redeliver it no sooner than delay from now.

impl Partitioned for PulsarMessage

fn partition_key(&self) -> Option<&[u8]>

Returns the partition key for this item, or None if the broker should pick a partition.

impl Positioned for PulsarMessage

type Position = PulsarPosition

The position type, matching the subscription’s Seeker::Position.

fn position(&self) -> PulsarPosition

Returns the position of this delivery; seeking to it redelivers this message.