Struct CorrelationInitializer 

pub struct CorrelationInitializer { /* private fields */ }

A convenience processor that ensures a correlation id is present on the inbound message and (optionally) mirrors it to a configurable header name for legacy compatibility.

This is useful to place at the start of a Route so downstream processors (splitters, aggregators, recipient lists, request/reply patterns) can assume that a stable correlation_id header exists. It reduces boilerplate and the chance of forgetting to set one, especially in heterogeneous pipelines.

Behavior

• If correlation_id header exists, it is left untouched.
• Otherwise a new UUID v4 is generated and stored under correlation_id.
• If mirror_header is set, that header key is also set to the same value.

Example

use allora_core::{patterns::correlation_initializer::CorrelationInitializer, processor::ClosureProcessor, route::Route, Exchange, Message};
let route = Route::new()
    .add(CorrelationInitializer::default())
    .add(ClosureProcessor::new(|exchange| { exchange.out_msg = Some(Message::from_text("done")); Ok(()) }))
    .build();
let mut exchange = Exchange::new(Message::from_text("hi"));
let rt = tokio::runtime::Runtime::new().unwrap();
rt.block_on(async { route.run(&mut exchange).await.unwrap(); });
assert!(exchange.in_msg.header("correlation_id").is_some());

Implementations

impl CorrelationInitializer

pub fn with_mirror<H>(header: H) -> CorrelationInitializer

where H: Into<String>,

Create with optional mirror header (e.g. legacy systems expect corr).

Trait Implementations

impl Clone for CorrelationInitializer

fn clone(&self) -> CorrelationInitializer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CorrelationInitializer

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

Formats the value using the given formatter.

impl Default for CorrelationInitializer

fn default() -> CorrelationInitializer

Returns the “default value” for a type.

impl Processor for CorrelationInitializer

fn process<'life0, 'life1, 'async_trait>( &'life0 self, exchange: &'life1 mut Exchange, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, CorrelationInitializer: 'async_trait,