Struct Publisher 

pub struct Publisher { /* private fields */ }

Simplified Publisher for message publishing

Implementations

impl Publisher

pub fn new(connection: Arc<Connection>) -> Self

Create a new publisher

pub async fn publish_to_exchange<T>( &self, exchange: &str, routing_key: &str, message: &T, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize,

Publish message to an exchange

pub async fn publish_to_queue<T>( &self, queue: &str, message: &T, options: Option<PublishOptions>, ) -> Result<(), RustRabbitError>

where T: Serialize,

Publish message directly to a queue