Struct ContentBasedRouter 

pub struct ContentBasedRouter { /* private fields */ }

Implementations

impl ContentBasedRouter

pub fn new<H: Into<String>>(header: H) -> Self

Create a new ContentBasedRouter instance, specifying the header name to inspect for routing. Example: ContentBasedRouter::new("x-my-header").

Panics

Panics if the header name is empty.

pub fn when<V: Into<String>>(self, value: V, proc: Box<dyn Processor>) -> Self

Add a route to the router, specifying a header value and the processor to handle messages with that value. Example: .when("value1", Box::new(my_processor)).

Panics

Panics if the value is empty.

Trait Implementations

impl Debug for ContentBasedRouter

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

Formats the value using the given formatter.

impl Processor for ContentBasedRouter

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

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process the exchange by delegating to the selected processor based on the content-based routing. Returns an error if no matching route is found.