Trait Channel 

pub trait Channel: Clone {
    // Required method
    fn publish_with_properties<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        payload_bytes: &'life1 [u8],
        routing_key: &'life2 str,
        properties: BasicProperties,
        correlation_uuid: Uuid,
        reply_uuid: Option<Uuid>,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
}

A RrabbitMQ channel

Required Methods

fn publish_with_properties<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, payload_bytes: &'life1 [u8], routing_key: &'life2 str, properties: BasicProperties, correlation_uuid: Uuid, reply_uuid: Option<Uuid>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Publish a message onto a queue

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl Channel for DirectChannel

impl Channel for RpcChannel

impl<E: TopicExchange> Channel for TopicChannel<E>