Struct SimpleMessageRouter

pub struct SimpleMessageRouter { /* private fields */ }

Simple message router implementation

Implementations

impl SimpleMessageRouter

pub fn new() -> SimpleMessageRouter

Create a new simple message router

Trait Implementations

impl MessageRouter for SimpleMessageRouter

fn add_route( &mut self, pattern: TopicPattern, handler: Box<dyn MessageHandler>, priority: u32, ) -> Result<(), NerveError>

Add a route for a topic pattern

fn remove_route(&mut self, pattern: &TopicPattern) -> Result<(), NerveError>

Remove a route

fn route_message( &self, _topic: &str, _message: &Message, ) -> Result<(), NerveError>

Route a message to appropriate handlers

fn statistics(&self) -> RoutingStatistics

Get routing statistics

fn clear_routes(&mut self) -> Result<(), NerveError>

Clear all routes