Trait Middleware 

pub trait Middleware: Send + Sync {
    // Required methods
    fn process(&self, message: Message) -> Result<Message, MiddlewareError>;
    fn name(&self) -> &'static str;

    // Provided method
    fn should_skip(&self, _message: &Message) -> bool { ... }
}

Middleware trait for message processing

Required Methods

fn process(&self, message: Message) -> Result<Message, MiddlewareError>

Process a message

fn name(&self) -> &'static str

Get the name of this middleware

Provided Methods

fn should_skip(&self, _message: &Message) -> bool

Check if this middleware should be skipped for a message

Implementors

impl Middleware for ContentTypeMiddleware

impl Middleware for PriorityMiddleware

impl Middleware for RetryLimitMiddleware

impl Middleware for SizeLimitMiddleware

impl Middleware for TaskNameFilterMiddleware

impl Middleware for ValidationMiddleware