Trait MessagePublisher 

pub trait MessagePublisher: Send + Sync {
    // Required method
    fn publish<'a>(
        &'a self,
        channel: &'a str,
        body: Vec<u8>,
        headers: HashMap<String, String>,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>;
}

Publish messages to channels by name.

Required Methods

fn publish<'a>( &'a self, channel: &'a str, body: Vec<u8>, headers: HashMap<String, String>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Implementors