Struct Exchange 

pub struct Exchange {
    pub in_msg: Message,
    pub out_msg: Option<Message>,
    pub properties: HashMap<String, String>,
}

An exchange wraps an inbound and outbound message, plus routing properties.

Inbound vs Outbound

• in_msg – original message entering the pipeline.
• out_msg – optional transformed result set by processors (e.g. formatter, enricher).

Properties

Free-form key/value pairs for internal routing state (e.g. retry count, timing info). Not automatically serialized; use headers for externally visible metadata.

Correlation Helper

Exchange::correlation_id provides a convenience wrapper around in_msg.ensure_correlation_id().

Fields

in_msg: Message

The inbound message.

out_msg: Option<Message>

The outbound message, if set.

properties: HashMap<String, String>

Arbitrary string properties for routing or context.

Implementations

impl Exchange

pub fn new(msg: Message) -> Exchange

Creates a new exchange with the given inbound message.

pub fn set_property<K, V>(&mut self, k: K, v: V)

where K: Into<String>, V: Into<String>,

Sets a property key-value pair.

pub fn property(&self, k: &str) -> Option<&str>

Returns the value of a property, if present.

pub fn correlation_id(&mut self) -> &str

Ensures the inbound message has a correlation id, returning it. Equivalent to self.in_msg.ensure_correlation_id(); provided for ergonomic chaining in routing code.

Trait Implementations

impl Clone for Exchange

fn clone(&self) -> Exchange

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Exchange

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

Formats the value using the given formatter.

impl Default for Exchange

fn default() -> Exchange

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Exchange

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Exchange

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.