Struct AMQPBroker 

pub struct AMQPBroker { /* private fields */ }

An AMQP broker.

Trait Implementations

impl Broker for AMQPBroker

fn reconnect<'life0, 'async_trait>( &'life0 self, connection_timeout: u32, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Try reconnecting in the event of some sort of connection error.

fn safe_url(&self) -> String

Return a string representation of the broker URL with any sensitive information redacted.

fn consume<'life0, 'life1, 'async_trait>( &'life0 self, queue: &'life1 str, _error_handler: Box<dyn Fn(BrokerError) + Send + Sync + 'static>, ) -> Pin<Box<dyn Future<Output = Result<(String, Box<dyn DeliveryStream>), BrokerError>> + Send + 'async_trait>>

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

Consume messages from a queue.

fn cancel<'life0, 'life1, 'async_trait>( &'life0 self, consumer_tag: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

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

Cancel the consumer with the given consumer_tag.

fn ack<'life0, 'life1, 'async_trait>( &'life0 self, delivery: &'life1 dyn Delivery, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

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

Acknowledge a Delivery for deletion.

fn retry<'life0, 'life1, 'async_trait>( &'life0 self, delivery: &'life1 dyn Delivery, eta: Option<DateTime<Utc>>, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

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

Retry a delivery.

fn send<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, message: &'life1 Message, queue: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

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

Send a Message into a queue.

fn increase_prefetch_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Increase the prefetch_count. This has to be done when a task with a future ETA is consumed.

fn decrease_prefetch_count<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Decrease the prefetch_count. This has to be done after a task with a future ETA is executed.

fn close<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), BrokerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Clone all channels and connection.