Module handler 

Handlers for acknowledging or rejecting messages.

To acknowledge (ack) a message, you call Handler::ack().

To reject (nack) a message, you drop() the handler. The message will be redelivered.

Example

use google_cloud_pubsub::model::Message;
fn on_message(m: Message, h: Handler) {
  match process(m) {
    Ok(_) => h.ack(),
    Err(e) => {
        println!("failed to process message: {e:?}");
        drop(h);
    }
  }
}

fn process(m: Message) -> anyhow::Result<()> {
  // some business logic here...
}

Structs

AtLeastOnce

A handler for at-least-once delivery.

ExactlyOnce

A handler for exactly-once delivery.

Enums

Handler

A handler for acknowledging or rejecting messages.