Struct ConsumerBuilder

pub struct ConsumerBuilder { /* private fields */ }

A non-consuming Consumer builder.

Implementations

impl ConsumerBuilder

pub fn new(conn: Connection) -> Self

pub fn exchange(&mut self, exchange: &str) -> &mut Self

Specify the exchange name.

pub fn queue(&mut self, queue: &str) -> &mut Self

Specify the queue name.

pub fn with_processor( &mut self, processor: Box<dyn MessageProcess + Send + Sync>, ) -> &mut Self

Use the provided MessageProcess trait object.

pub async fn build(&self) -> Result<Consumer, Error>

Trait Implementations

impl Clone for ConsumerBuilder

fn clone(&self) -> ConsumerBuilder

Returns a copy of the value.

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

Performs copy-assignment from source.