Struct ConsumerOptionsBuilder 

pub struct ConsumerOptionsBuilder { /* private fields */ }

Builder for ConsumerOptions

Implementations

impl ConsumerOptionsBuilder

pub fn new(queue_name: String) -> Self

Create a new builder with default values

pub fn consumer_tag<S: Into<String>>(self, tag: S) -> Self

Set consumer tag

pub fn concurrency(self, concurrency: usize) -> Self

Set concurrency level

pub fn prefetch_count(self, count: u16) -> Self

Set prefetch count

pub fn no_prefetch_limit(self) -> Self

Disable prefetch limit

pub fn auto_declare_queue(self) -> Self

Enable auto-declare queue

pub fn auto_declare_exchange(self) -> Self

Enable auto-declare exchange and bind to queue

pub fn exchange_name<S: Into<String>>(self, name: S) -> Self

Set exchange name (if not set, uses queue_name)

pub fn exchange_options(self, options: CustomExchangeDeclareOptions) -> Self

Set exchange options

pub fn routing_key<S: Into<String>>(self, key: S) -> Self

Set routing key for binding (default: queue_name)

pub fn queue_options(self, options: CustomQueueDeclareOptions) -> Self

Set queue options

pub fn retry_policy(self, policy: RetryPolicy) -> Self

Set retry policy

pub fn dead_letter_exchange<S: Into<String>>(self, exchange: S) -> Self

Set dead letter exchange

pub fn auto_ack(self) -> Self

Enable auto-ack (not recommended for production)

pub fn manual_ack(self) -> Self

Enable manual ack (recommended for production)

pub fn exclusive(self) -> Self

Enable exclusive mode

pub fn high_throughput(self) -> Self

Configure for high throughput

pub fn reliable(self) -> Self

Configure for reliability (lower throughput but safer)

pub fn development(self) -> Self

Configure for development (simpler settings)

pub fn minutes_retry(self) -> Self

Configure for minutes exponential retry (1min, 2min, 4min, 8min, 16min - max 5 retries) This preset automatically sets up:

• Auto declare queue and exchange
• Retry policy with minutes exponential backoff
• Dead letter exchange/queue based on queue name
• Reliable processing settings

pub fn build(self) -> ConsumerOptions

Build the final configuration

Trait Implementations

impl Clone for ConsumerOptionsBuilder

fn clone(&self) -> ConsumerOptionsBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ConsumerOptionsBuilder

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.