Struct MessageRouter 

pub struct MessageRouter<T: Send + Sync + 'static> { /* private fields */ }

Routes incoming messages to handlers based on topic patterns.

Supports exact-match and simple wildcard patterns where * matches any sequence of characters.

Example

use rskit_messaging::router::MessageRouter;

let router = MessageRouter::<String>::new()
    .handle("orders.created", order_handler)
    .handle("orders.*", fallback_handler)
    .default_handler(catch_all)
    .build();

Implementations

impl<T: Send + Sync + 'static> MessageRouter<T>

pub fn new() -> Self

Create a new empty router.

pub fn handle(self, pattern: &str, handler: Arc<dyn MessageHandler<T>>) -> Self

Register a handler for the given topic pattern.

Patterns support * as a wildcard that matches any sequence of characters. For example, "content.*" matches "content.discovered". Patterns are evaluated in registration order; the first match wins.

pub fn default_handler(self, handler: Arc<dyn MessageHandler<T>>) -> Self

Register a default handler for messages that match no pattern.

pub fn build(self) -> Arc<dyn MessageHandler<T>>

Build an Arc<dyn MessageHandler<T>> that dispatches messages according to the registered patterns.

Trait Implementations

impl<T: Send + Sync + 'static> Default for MessageRouter<T>

fn default() -> Self

Returns the “default value” for a type.