Struct AMQPBrokerBuilder 

pub struct AMQPBrokerBuilder { /* private fields */ }

Builds an AMQPBroker with a custom configuration.

Trait Implementations

impl BrokerBuilder for AMQPBrokerBuilder

fn new(broker_url: &str) -> Self

Create a new AMQPBrokerBuilder.

fn prefetch_count( self: Box<Self>, prefetch_count: u16, ) -> Box<dyn BrokerBuilder>

Set the worker prefetch count.

fn declare_queue(self: Box<Self>, name: &str) -> Box<dyn BrokerBuilder>

Declare a queue.

fn heartbeat(self: Box<Self>, heartbeat: Option<u16>) -> Box<dyn BrokerBuilder>

Set the heartbeat.

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

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

Build an AMQPBroker.