Struct PriorityRouter 

pub struct PriorityRouter { /* private fields */ }

Priority-based router

Implementations

impl PriorityRouter

pub fn new( high_priority_queue: impl Into<String>, normal_priority_queue: impl Into<String>, low_priority_queue: impl Into<String>, ) -> Self

Create a new priority-based router

pub fn with_thresholds(self, high: u8, low: u8) -> Self

Set priority thresholds

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

Get the queue for a message based on priority

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

Group messages by priority queue