Struct RabbitConsumer 

pub struct RabbitConsumer { /* private fields */ }

A struct representing a RabbitMQ consumer. It manages connection, channel, and message consumption from a specified queue.

Implementations

impl RabbitConsumer

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

Establishes a new RabbitConsumer by connecting to a RabbitMQ broker and binding a queue to an exchange.

Parameters

• uri - The RabbitMQ connection URI.
• queue_name - The name of the queue to consume from.

Returns

A configured RabbitConsumer.

pub async fn load_messages<T, C>( &self, channel_capacity: usize, consumer_tag: Option<C>, ) -> Result<Receiver<T>>

where T: DeserializeOwned + Send + Sync + 'static, C: Into<String> + Debug,

Loads messages from the queue and automatically acknowledges them upon receipt.

Parameters

• channel_capacity - Internal channel buffer size.
• consumer_tag - Identifier used for consumer instance.

Returns

An mpsc::Receiver<T> for consuming deserialized messages.

pub async fn load_ackable_messages<T, C>( &self, channel_capacity: usize, consumer_tag: Option<C>, ) -> Result<Receiver<AckableMessage<T>>>

where T: DeserializeOwned + Send + Sync + 'static, C: Into<String> + Debug,

Loads messages from the queue that require manual acknowledgement.

Parameters

• channel_capacity - Internal channel buffer size.
• consumer_tag - Identifier used for consumer instance.

Returns

An mpsc::Receiver<AckableMessage<T>> for consuming messages with manual acknowledgment.

Trait Implementations

impl Debug for RabbitConsumer

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

Formats the value using the given formatter.