Struct ReceivedMessage 

pub struct ReceivedMessage {
    pub message: PubsubMessage,
    pub ack_id: String,
    pub subscription: String,
    pub subscriber_client: SubscriberClient,
    pub delivery_attempt: Option<usize>,
}

Fields

message: PubsubMessage

ack_id: String

subscription: String

subscriber_client: SubscriberClient

delivery_attempt: Option<usize>

Implementations

impl ReceivedMessage

pub fn ack_id(&self) -> &str

pub async fn ack(&self) -> Result<(), Status>

pub async fn nack(&self) -> Result<(), Status>

pub async fn modify_ack_deadline( &self, ack_deadline_seconds: i32, ) -> Result<(), Status>

pub fn delivery_attempt(&self) -> Option<usize>

The approximate number of times that Cloud Pub/Sub has attempted to deliver the associated message to a subscriber.

The returned value, if present, will be greater than zero.

For more information refer to the protobuf definition.

Trait Implementations

impl Clone for ReceivedMessage

fn clone(&self) -> ReceivedMessage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ReceivedMessage

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

Formats the value using the given formatter.