Struct RoutingKeyMiddleware 

pub struct RoutingKeyMiddleware { /* private fields */ }

Middleware for dynamic routing key assignment.

Assigns routing keys to messages based on custom logic or message content. Useful for implementing dynamic routing strategies.

Examples

use celers_kombu::{RoutingKeyMiddleware, MessageMiddleware};

// Use task name as routing key
let middleware = RoutingKeyMiddleware::new(|msg| {
    format!("tasks.{}", msg.headers.task)
});
assert_eq!(middleware.name(), "routing_key");

Implementations

impl RoutingKeyMiddleware

pub fn new<F>(key_generator: F) -> Self

where F: Fn(&Message) -> String + Send + Sync + 'static,

Create a new routing key middleware with a custom key generator

pub fn from_task_name() -> Self

Create a routing key from task name

pub fn from_task_and_priority() -> Self

Create a routing key from task name with priority

Trait Implementations

impl MessageMiddleware for RoutingKeyMiddleware

fn before_publish<'life0, 'life1, 'async_trait>( &'life0 self, message: &'life1 mut Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process message before publishing

fn after_consume<'life0, 'life1, 'async_trait>( &'life0 self, _message: &'life1 mut Message, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process message after consuming

fn name(&self) -> &str

Get middleware name for logging