Struct MessageContext 

pub struct MessageContext { /* private fields */ }

Re-exported public API. Context made available to a microservice handler.

Implementations

impl MessageContext

pub fn new( subject: impl Into<String>, headers: BTreeMap<String, String>, correlation_id: Option<String>, deadline: Option<SystemTime>, cancellation: CancellationToken, delivery: Option<MessageDelivery>, event_id: Option<String>, ) -> Self

Creates a context for a transport delivery.

pub fn subject(&self) -> &str

The subject that delivered this message.

pub fn headers(&self) -> &BTreeMap<String, String>

Application headers propagated by the transport.

pub fn correlation_id(&self) -> Option<&str>

The request correlation identifier, when this is a command.

pub fn deadline(&self) -> Option<SystemTime>

The requested deadline, when one was propagated.

pub fn cancellation_token(&self) -> &CancellationToken

A token cancelled when the application begins shutdown.

pub fn delivery(&self) -> Option<&MessageDelivery>

Delivery metadata for durable events.

pub fn delivery_attempt(&self) -> u64

The one-based delivery attempt, or zero for non-durable commands.

pub fn event_id(&self) -> Option<&str>

The stable event envelope ID, when this is a durable event delivery.

Trait Implementations

impl Clone for MessageContext

fn clone(&self) -> MessageContext

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageContext

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

Formats the value using the given formatter.