[−][src]Trait celery::Broker
Associated Types
type Delivery: TryIntoMessage + Clone + Debug
type DeliveryError: Into<Error>
type Consumer: IntoIterator<Item = Result<Self::Delivery, Self::DeliveryError>, IntoIter = Self::ConsumerIterator> + Stream<Item = Result<Self::Delivery, Self::DeliveryError>> + StreamExt
type ConsumerIterator: Iterator<Item = Result<Self::Delivery, Self::DeliveryError>>
Required methods
fn consume<'life0, 'life1, 'async_trait>(
&'life0 self,
queue: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Self::Consumer, Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
&'life0 self,
queue: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Self::Consumer, Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn ack<'life0, 'async_trait>(
&'life0 self,
delivery: Self::Delivery
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
&'life0 self,
delivery: Self::Delivery
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn send<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 Message,
queue: &'life2 str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
&'life0 self,
message: &'life1 Message,
queue: &'life2 str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
Implementors
impl Broker for AMQPBroker
[src]
type Delivery = Delivery
type DeliveryError = Error
type Consumer = Consumer
type ConsumerIterator = ConsumerIterator
fn consume<'life0, 'life1, 'async_trait>(
&'life0 self,
queue: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Self::Consumer, Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
queue: &'life1 str
) -> Pin<Box<dyn Future<Output = Result<Self::Consumer, Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,
fn ack<'life0, 'async_trait>(
&'life0 self,
delivery: Self::Delivery
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
delivery: Self::Delivery
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
Self: 'async_trait,
fn send<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
message: &'life1 Message,
queue: &'life2 str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,
[src]
&'life0 self,
message: &'life1 Message,
queue: &'life2 str
) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
Self: 'async_trait,