Struct QueueConsumer 

pub struct QueueConsumer<T> { /* private fields */ }

Lapin-backed consumer for JSON messages of type T.

T is the message payload deserialized from each delivery body. The consumer holds one channel bound to queue_name with the given options.

Implementations

impl<T> QueueConsumer<T>

where T: DeserializeOwned + Send + Sync + 'static,

pub async fn connect( addr: &str, queue_name: &str, options: PublishOptions, ) -> Result<Self>

Connects to the broker, opens a channel, and applies the prefetch count.

Returns an error if the connection, channel, or QoS setup fails.

pub async fn declare(&self) -> Result<()>

Declares the durable main queue plus the retry and dead-letter queues when enabled.

The retry queues dead-letters back to the main queue after retry_interval_ms. Returns an error if any declaration fails.

pub async fn consume<F, Fut>(&self, handler: F) -> Result<()>

where F: FnMut(T, bool) -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send,

Consumes deliveries in a loop, acknowledging successes and rerouting failures.

handler receives each decoded message plus its redelivered flag and returns success or failure. Successful handlers are acknowledged; handler errors, timeouts, and undecodable bodies go through the retry/dead-letter policy. F is the handler closure type and Fut its returned future. Runs until the broker stream ends.