Struct QueueMessage 

pub struct QueueMessage {
    pub id: u64,
    pub name: String,
    pub body: Vec<u8>,
    pub created_at: i64,
    pub trace_context: IncomingTraceContext,
    /* private fields */
}

Fields

id: u64

name: String

body: Vec<u8>

created_at: i64

trace_context: IncomingTraceContext

Ray ID and span of the invocation that sent the message, which the span covering its receipt links back to. Empty when the sender carried no trace context.

Implementations

impl QueueMessage

pub async fn complete(self, response: Option<Vec<u8>>) -> Result<()>

pub fn into_completable(self) -> Result<CompletableQueueMessage>

pub fn is_completable(&self) -> bool

Trait Implementations

impl Clone for QueueMessage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueMessage

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

Formats the value using the given formatter.