Struct Message 

pub struct Message {
    pub message_id: String,
    pub data: Bytes,
    pub attributes: HashMap<String, String>,
    /* private fields */
}

Incoming Pub/Sub payload plus shared acknowledgement state

Fields

message_id: String

data: Bytes

attributes: HashMap<String, String>

Implementations

impl Message

pub fn ack(&self)

Acknowledge this message (at-least-once best-effort semantics from the client library).

pub fn nack(&self)

Negative acknowledgement: the message may be redelivered.

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Drop for Message

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl FromPubSubMsg for Message

fn from_pubsub(grpc: &Message, env: &PubSubEnvelope, _app: &App) -> Self