Struct pgmq::Message

pub struct Message<T = Value> {
    pub msg_id: i64,
    pub vt: DateTime<Utc>,
    pub enqueued_at: DateTime<Utc>,
    pub read_ct: i32,
    pub message: T,
}

Message struct received from the queue

It is an “envelope” for the message that is stored in the queue. It contains both the message body but also metadata about the message.

Fields

msg_id: i64

unique identifier for the message

vt: DateTime<Utc>

“visibility time”. The UTC timestamp at which the message will be available for reading again.

enqueued_at: DateTime<Utc>

UTC timestamp that the message was sent to the queue

read_ct: i32

The number of times the message has been read. Increments on read.

message: T

The message body.

Trait Implementations

impl<T> Clone for Message<T>

where T: Clone,

fn clone(&self) -> Message<T>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T> Debug for Message<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<'de, T> Deserialize<'de> for Message<T>

where T: Deserialize<'de>,

fn deserialize<__D>( __deserializer: __D ) -> Result<Message<T>, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a, R, T> FromRow<'a, R> for Message<T>

where R: Row, &'a str: ColumnIndex<R>, i64: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, DateTime<Utc>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, i32: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, T: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>,

fn from_row(row: &'a R) -> Result<Message<T>, Error>