Struct PriorityRouter 

pub struct PriorityRouter { /* private fields */ }

Priority-based message router

Implementations

impl PriorityRouter

pub fn new(default_queue: String) -> Self

pub fn add_queue(&mut self, name: String, queue: Arc<PriorityQueue>)

Add a priority queue for a specific topic/route

pub fn route_message( &self, queue_name: Option<String>, message: PriorityMessage, ) -> Result<()>

Route message to appropriate priority queue

pub async fn dequeue_any(&self) -> Option<(String, PriorityMessage)>

Get message from highest priority across all queues

pub fn get_queue(&self, name: &str) -> Option<Arc<PriorityQueue>>

Get queue by name

pub fn queue_names(&self) -> Vec<String>

Get all queue names

pub fn aggregate_stats(&self) -> HashMap<String, PriorityQueueStats>

Get aggregate statistics across all queues

Trait Implementations

impl Debug for PriorityRouter

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

Formats the value using the given formatter.