Struct TopicRouter 

pub struct TopicRouter { /* private fields */ }

Topic exchange router for AMQP-style topic routing

Routes messages based on topic patterns with wildcards.

Implementations

impl TopicRouter

pub fn new() -> Self

Create a new topic router

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

Bind a topic pattern to a queue

pub fn bind_many(&mut self, patterns: Vec<String>, queue: impl Into<String>)

Bind multiple patterns to a queue

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

Set default queue for unmatched routing keys

pub fn route(&self, routing_key: &str) -> Option<String>

Route a message based on routing key

Returns the first matching queue, or the default queue if no match.

pub fn route_all(&self, routing_key: &str) -> Vec<String>

Get all queues that match a routing key

pub fn unbind_queue(&mut self, queue: &str) -> usize

Remove all bindings for a queue

pub fn unbind_pattern(&mut self, pattern: &str) -> bool

Remove a specific binding

pub fn bindings(&self) -> Vec<(String, String)>

Get all bindings

pub fn clear(&mut self)

Clear all bindings

pub const fn binding_count(&self) -> usize

Get number of bindings

pub fn has_match(&self, routing_key: &str) -> bool

Check if a routing key has any matches

Trait Implementations

impl Clone for TopicRouter

fn clone(&self) -> TopicRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicRouter

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

Formats the value using the given formatter.

impl Default for TopicRouter

fn default() -> Self

Returns the “default value” for a type.