Struct IncomingMessage 

#[non_exhaustive]
pub struct IncomingMessage<T> {
    pub topic: Arc<TopicMatch>,
    pub meta: Arc<MessageMeta>,
    pub payload: T,
}

A successfully delivered message: its decoded payload plus the context that arrived with it. topic and meta are shared (Arc) across every subscriber of the same publish; payload is this subscriber’s own decoded value.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

topic: Arc<TopicMatch>

The concrete topic the message arrived on (wildcards resolved).

meta: Arc<MessageMeta>

Per-message protocol metadata (QoS, retain, dup, …).

payload: T

The decoded payload.

Implementations

impl<T> IncomingMessage<T>

pub fn new( topic: Arc<TopicMatch>, meta: Arc<MessageMeta>, payload: T, ) -> IncomingMessage<T>

Construct an incoming message. The library builds these on the receive path; it is public so downstream tests can construct one (the type is #[non_exhaustive], so a struct literal is not available off-crate).

Trait Implementations

impl<T> Debug for IncomingMessage<T>

where T: Debug,

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

Formats the value using the given formatter.