Struct ReceivedMessage 

pub struct ReceivedMessage {
    pub message_id: String,
    pub data: Bytes,
    pub attributes: HashMap<String, String>,
    pub publish_time: DateTime<Utc>,
    pub ordering_key: Option<String>,
    pub delivery_attempt: i32,
    /* private fields */
}

Received message from Pub/Sub.

Fields

message_id: String

Message ID.

data: Bytes

Message data payload.

attributes: HashMap<String, String>

Message attributes.

publish_time: DateTime<Utc>

Publish timestamp.

ordering_key: Option<String>

Ordering key if present.

delivery_attempt: i32

Delivery attempt count.

Implementations

impl ReceivedMessage

pub fn size(&self) -> usize

Gets the size of the message in bytes.

pub fn is_redelivery(&self) -> bool

Checks if this is a redelivery.

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.