Struct MessageRouter 

pub struct MessageRouter { /* private fields */ }

Router for directing messages to queues

Implementations

impl MessageRouter

pub fn new(default_queue: impl Into<String>) -> Self

Create a new message router with a default queue

pub fn add_rule(&mut self, rule: RoutingRule)

Add a routing rule

pub fn route(&mut self, pattern: impl Into<String>, queue: impl Into<String>)

Add a simple routing rule (pattern -> queue)

pub fn get_queue(&self, message: &Message) -> &str

Get the queue name for a message

pub fn get_queue_for_task(&self, task_name: &str) -> &str

Get the queue name for a task name

pub fn get_routing_key(&self, message: &Message) -> Option<&str>

Get the routing key for a message

pub fn get_exchange(&self, message: &Message) -> Option<&str>

Get the exchange for a message

pub fn group_by_queue( &self, messages: Vec<Message>, ) -> HashMap<String, Vec<Message>>

Group messages by their target queues

Trait Implementations

impl Clone for MessageRouter

fn clone(&self) -> MessageRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageRouter

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

Formats the value using the given formatter.