Struct RiRabbitMQQueue 

pub struct RiRabbitMQQueue { /* private fields */ }

RabbitMQ queue implementation for the Ri queue system.

This struct provides a RabbitMQ implementation of the RiQueue trait, allowing sending and receiving messages using RabbitMQ as the underlying message broker.

Implementations

impl RiRabbitMQQueue

pub async fn new(name: &str, connection_string: &str) -> RiResult<Self>

Creates a new RabbitMQ queue instance.

Parameters

• name: The name of the queue
• connection_string: The RabbitMQ connection string

Returns

A new RiRabbitMQQueue instance wrapped in RiResult

pub async fn new_with_connection( name: &str, connection: Connection, ) -> RiResult<Self>

Creates a new RabbitMQ queue instance with an existing connection.

Parameters

• name: The name of the queue
• connection: The existing RabbitMQ connection

Returns

A new RiRabbitMQQueue instance wrapped in RiResult

pub async fn new_with_management( name: &str, connection: Connection, management_url: &str, management_username: &str, management_password: &str, ) -> RiResult<Self>

Creates a new RabbitMQ queue instance with management API support.

Parameters

• name: The name of the queue
• connection: The existing RabbitMQ connection
• management_url: RabbitMQ management API URL (e.g., “http://localhost:15672”)
• management_username: Management API username
• management_password: Management API password

Returns

A new RiRabbitMQQueue instance wrapped in RiResult

Trait Implementations

impl RiQueue for RiRabbitMQQueue

fn create_producer<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<Box<dyn RiQueueProducer>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Creates a new producer for the RabbitMQ queue.

Returns

A new RiQueueProducer instance wrapped in RiResult

fn create_consumer<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = RiResult<Box<dyn RiQueueConsumer>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Creates a new consumer for the RabbitMQ queue.

Parameters

• consumer_group: The consumer group name

Returns

A new RiQueueConsumer instance wrapped in RiResult

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<RiQueueStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gets statistics for the RabbitMQ queue.

This implementation integrates with RabbitMQ management API to provide detailed queue statistics including message counts, consumer counts, and processing metrics.

Returns

RiQueueStats containing detailed queue statistics wrapped in RiResult

fn purge<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Purges all messages from the RabbitMQ queue.

Returns

RiResult indicating success or failure Purges all messages from the RabbitMQ queue.

Returns

RiResult indicating success or failure

fn delete<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = RiResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Deletes the RabbitMQ queue.

Returns

RiResult indicating success or failure