Struct celery::broker::AMQPBroker
source · pub struct AMQPBroker { /* private fields */ }
Expand description
An AMQP broker.
Trait Implementations§
source§impl Broker for AMQPBroker
impl Broker for AMQPBroker
source§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,
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.
source§fn safe_url(&self) -> String
fn safe_url(&self) -> String
Return a string representation of the broker URL with any sensitive information
redacted.
source§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,
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. Read more
source§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,
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
.source§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,
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.source§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,
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.
source§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,
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.source§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,
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.source§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,
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.Auto Trait Implementations§
impl !RefUnwindSafe for AMQPBroker
impl Send for AMQPBroker
impl Sync for AMQPBroker
impl Unpin for AMQPBroker
impl !UnwindSafe for AMQPBroker
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more