Struct MessageVersioningMiddleware 

pub struct MessageVersioningMiddleware { /* private fields */ }

Message versioning middleware - handle message schema versions

Examples

use celers_kombu::MessageVersioningMiddleware;

// Basic versioning with current version
let versioning = MessageVersioningMiddleware::new("2.0");

// With backward compatibility
let compat_versioning = MessageVersioningMiddleware::new("3.0")
    .with_min_supported_version("2.5")
    .with_auto_upgrade(true);

Implementations

impl MessageVersioningMiddleware

pub fn new(current_version: impl Into<String>) -> Self

Create a new message versioning middleware

pub fn with_min_supported_version(self, version: impl Into<String>) -> Self

Set minimum supported version

pub fn with_auto_upgrade(self, enabled: bool) -> Self

Enable auto-upgrade of messages

Trait Implementations

impl MessageMiddleware for MessageVersioningMiddleware

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