Struct RouteRule 

pub struct RouteRule {
    pub matcher: PatternMatcher,
    pub queue: String,
    pub priority: i32,
    pub routing_key: Option<String>,
    pub exchange: Option<String>,
    pub argument_condition: Option<ArgumentCondition>,
}

A routing rule that maps task names to queues

Fields

matcher: PatternMatcher

Pattern matcher for task names

queue: String

Target queue name

priority: i32

Rule priority (higher = evaluated first)

routing_key: Option<String>

Optional routing key (for AMQP exchanges)

exchange: Option<String>

Optional exchange name (for AMQP)

argument_condition: Option<ArgumentCondition>

Optional argument condition for argument-based routing

Implementations

impl RouteRule

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

Create a new routing rule

pub fn with_priority(self, priority: i32) -> Self

Set the rule priority

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

Set the routing key (for AMQP)

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

Set the exchange name (for AMQP)

pub fn with_argument_condition(self, condition: ArgumentCondition) -> Self

Set the argument condition for argument-based routing

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

Check if this rule matches a task name

pub fn matches_with_args( &self, task_name: &str, args: &[Value], kwargs: &Map<String, Value>, ) -> bool

Check if this rule matches a task name and arguments

Returns true if:

• The task name matches the pattern matcher
• AND (if argument_condition is set) the arguments match the condition

Trait Implementations

impl Clone for RouteRule

fn clone(&self) -> RouteRule

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RouteRule

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

Formats the value using the given formatter.