Enum MessageIdSource 

pub enum MessageIdSource {
    Sync(Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>),
    Async(Arc<dyn Fn(&Exchange) -> BoxValueFuture + Send + Sync>),
}

Fallible message-id source for the idempotent consumer.

The sync arm returns None when no key can be extracted — in that case the segment forwards the exchange to the child sub-pipeline without idempotency (matching Apache Camel semantics). The async arm may fail with a camel_api::CamelError; the failure fails the step before the child runs. Non-scalar values (array/object) are rejected.

Variants

Sync(Arc<dyn Fn(&Exchange) -> Option<String> + Send + Sync>)

Programmatic synchronous extractor.

Async(Arc<dyn Fn(&Exchange) -> BoxValueFuture + Send + Sync>)

Language-backed asynchronous expression.

Implementations

impl MessageIdSource

pub async fn message_id( &self, exchange: &Exchange, ) -> Result<Option<String>, CamelError>

Extract the optional message id, propagating async failures.

Trait Implementations

impl Clone for MessageIdSource

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.