amqp-bridge 0.2.5

AMQP bridge
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use anyhow::Result;
use async_trait::async_trait;
use lapin::BasicProperties;

pub struct Message {
    pub data: Vec<u8>,
    pub properties: BasicProperties,
}

#[async_trait]
pub trait MessageTransformer: Send + Sync {
    /// Transform an incoming AMQP `Message` into a new `Message` before publish.
    ///
    /// # Errors
    /// Implementations may return an error when transformation fails, e.g.
    /// invalid payloads, schema violations, or other application-specific
    /// conditions that prevent producing an output message.
    async fn transform(&self, input: Message) -> Result<Message>;
}