Struct DMSCRabbitMQQueue 

pub struct DMSCRabbitMQQueue { /* private fields */ }

RabbitMQ queue implementation for the DMSC queue system.

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

Implementations

impl DMSCRabbitMQQueue

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

Creates a new RabbitMQ queue instance.

Parameters

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

Returns

A new DMSCRabbitMQQueue instance wrapped in DMSCResult

pub async fn new_with_connection( name: &str, connection: Connection, ) -> DMSCResult<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 DMSCRabbitMQQueue instance wrapped in DMSCResult

pub async fn new_with_management( name: &str, connection: Connection, management_url: &str, management_username: &str, management_password: &str, ) -> DMSCResult<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 DMSCRabbitMQQueue instance wrapped in DMSCResult

Trait Implementations

impl DMSCQueue for DMSCRabbitMQQueue

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

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

Creates a new producer for the RabbitMQ queue.

Returns

A new DMSCQueueProducer instance wrapped in DMSCResult

fn create_consumer<'life0, 'life1, 'async_trait>( &'life0 self, consumer_group: &'life1 str, ) -> Pin<Box<dyn Future<Output = DMSCResult<Box<dyn DMSCQueueConsumer>>> + 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 DMSCQueueConsumer instance wrapped in DMSCResult

fn get_stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = DMSCResult<DMSCQueueStats>> + 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

DMSCQueueStats containing detailed queue statistics wrapped in DMSCResult

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

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

Purges all messages from the RabbitMQ queue.

Returns

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

Returns

DMSCResult indicating success or failure

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

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

Deletes the RabbitMQ queue.

Returns

DMSCResult indicating success or failure