broccoli_queue 0.4.6

Broccoli is a simple, fast, and reliable job queue for Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42


use crate::{
    brokers::management::{BrokerWithManagement, QueueManagement, QueueStatus, QueueType},
    error::BroccoliError,
};

use super::RabbitMQBroker;

#[async_trait::async_trait]
impl QueueManagement for RabbitMQBroker {
    async fn get_queue_status(
        &self,
        queue_name: String,
        disambiguator: Option<String>,
    ) -> Result<QueueStatus, BroccoliError> {
        let pool = self.ensure_pool()?;
        let conn = pool
            .get()
            .await
            .map_err(|e| BroccoliError::Consume(format!("Failed to consume message: {e:?}")))?;
        let _channel = conn.create_channel().await.map_err(|e| {
            BroccoliError::Consume(format!("Failed to create channel: {e:?}"))
        })?;
        
        // List queues through management API or channel operations
        // This is a simplified version - in practice you'd want to use the RabbitMQ Management API
        let statuses = QueueStatus {
            name: queue_name,
            queue_type: QueueType::Main,
            size: 0,
            processing: 0,
            failed: 0,
            disambiguator_count: None,
        };

        // Implementation note: RabbitMQ doesn't provide memory usage through regular AMQP
        // You would need to use the HTTP Management API to get this information
        Ok(statuses)
    }
}

impl BrokerWithManagement for RabbitMQBroker {}