Struct AtLeastOnce 

pub struct AtLeastOnce { /* private fields */ }

A handler for at-least-once delivery.

Implementations

impl AtLeastOnce

pub fn ack(self)

Acknowledge the message associated with this handler.

Note that the acknowledgement is best effort. The message may still be redelivered to this client, or another client.

pub fn nack(self)

Rejects the message associated with this handler.

Example

use google_cloud_pubsub::model::Message;
fn on_message(m: Message, h: AtLeastOnce) {
  println!("Received message: {m:?}");
  h.nack();
}

The message will be removed from this Subscriber’s lease management. The service will redeliver this message, possibly to another client.

Trait Implementations

impl Debug for AtLeastOnce

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

Formats the value using the given formatter.

impl Drop for AtLeastOnce

fn drop(&mut self)

Rejects the message associated with this handler.

The message will be removed from this Subscriber’s lease management. The service will redeliver this message, possibly to another client.