Struct RoutingRule 

pub struct RoutingRule {
    pub pattern: String,
    pub queue: String,
    pub routing_key: Option<String>,
    pub exchange: Option<String>,
}

Routing rule for directing messages to queues

Fields

pattern: String

Task name pattern (supports prefix matching with ‘*’)

queue: String

Target queue name

routing_key: Option<String>

Optional routing key

exchange: Option<String>

Optional exchange name

Implementations

impl RoutingRule

pub fn new(pattern: impl Into<String>, queue: impl Into<String>) -> Self

Create a new routing rule

pub fn with_routing_key(self, routing_key: impl Into<String>) -> Self

Set the routing key

pub fn with_exchange(self, exchange: impl Into<String>) -> Self

Set the exchange

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

Check if this rule matches a task name

Trait Implementations

impl Clone for RoutingRule

fn clone(&self) -> RoutingRule

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RoutingRule

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

Formats the value using the given formatter.