Struct ConsumerBuilder 

pub struct ConsumerBuilder { /* private fields */ }

Consumer configuration builder

Implementations

impl ConsumerBuilder

pub fn new(connection: Arc<Connection>, queue_name: impl Into<String>) -> Self

pub fn bind_to_exchange( self, exchange: impl Into<String>, routing_key: impl Into<String>, ) -> Self

Bind to an exchange with routing key

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

Set routing key (for use with bind_to_exchange)

pub fn with_retry(self, retry_config: RetryConfig) -> Self

Configure retry behavior

pub fn with_dlq_ttl(self, ttl: Duration) -> Self

Set TTL for dead letter queue (auto-cleanup failed messages) This is a convenience method that modifies the retry_config if it exists

Example

let consumer = Consumer::builder(connection, "orders")
    .with_retry(RetryConfig::exponential_default())
    .with_dlq_ttl(Duration::from_secs(86400))  // 1 day
    .build();

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

Set prefetch count

pub fn manual_ack(self) -> Self

Disable auto-acknowledge (manual ack required)

pub fn build(self) -> Consumer

Build the consumer