Struct Publisher 

pub struct Publisher { /* private fields */ }

Publisher for sending messages to RabbitMQ

Implementations

impl Publisher

pub fn new(connection_manager: ConnectionManager) -> Self

Create a new publisher

pub fn set_metrics(&mut self, metrics: RustRabbitMetrics)

Set metrics for this publisher

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

where T: Serialize,

Publish a message to a queue

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

where T: Serialize,

Publish a message to an exchange

pub async fn publish_delayed<T>( &self, exchange_name: &str, routing_key: &str, message: &T, delay: Duration, options: Option<PublishOptions>, ) -> Result<()>

where T: Serialize,

Publish a delayed message using the delayed message exchange plugin

pub async fn publish_with_ttl<T>( &self, exchange_name: &str, routing_key: &str, message: &T, ttl: Duration, options: Option<PublishOptions>, ) -> Result<()>

where T: Serialize,

Publish a message with TTL (Time To Live)

Trait Implementations

impl Clone for Publisher

fn clone(&self) -> Publisher

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Publisher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.