Struct MessageRouter 

pub struct MessageRouter {
    pub stats: Arc<RouterStats>,
    /* private fields */
}

Priority-based message router with per-handler queues and a dead-letter queue.

Thread safety

All public methods are safe to call from multiple threads simultaneously. Handlers are protected by a RwLock; per-handler queues and the dead-letter queue are protected by a Mutex.

Fields

stats: Arc<RouterStats>

Aggregate statistics.

Implementations

impl MessageRouter

pub fn new() -> Self

Create a new, empty MessageRouter.

pub fn next_id(&self) -> u64

Allocate the next monotonic message ID.

pub fn register_handler( &self, reg: HandlerRegistration, ) -> Result<(), RouterError>

Register a new handler.

Returns RouterError::DuplicateHandler if a handler with the same handler_id is already registered.

pub fn unregister_handler(&self, handler_id: &str)

Unregister a handler by handler_id.

This is a no-op if the handler does not exist (no error is returned so callers can safely call this during shutdown without worrying about race conditions with double-unregister).

pub fn handler_count(&self) -> usize

Return the number of currently registered handlers.

pub fn route(&self, msg: RoutedMessage) -> usize

Route msg to all matching handlers.

Returns the number of handlers the message was dispatched to. When no handler matches, the message is pushed onto the dead-letter queue (evicting the oldest entry if the queue is full).

Messages that are already expired on arrival are counted as total_expired_dropped and discarded immediately.

pub fn drain_for_handler(&self, handler_id: &str) -> Vec<RoutedMessage>

Drain all queued messages for handler_id in priority order (highest first).

Returns an empty Vec if the handler has no queued messages or is unknown.

pub fn dead_letter_count(&self) -> usize

Return the current number of messages in the dead-letter queue.

pub fn drain_dead_letter(&self) -> Vec<RoutedMessage>

Drain and return all messages from the dead-letter queue.

Trait Implementations

impl Default for MessageRouter

fn default() -> Self

Returns the “default value” for a type.