Method queue_status

src/queue.rs:1097–1106

(
        &self,
        queue_name: String,
        disambiguator: Option<String>,
    )

    /// If the queue status fails to be retrieved, a `BroccoliError` will be returned.
    #[cfg(feature = "management")]
    pub async fn queue_status(
        &self,
        queue_name: String,
        disambiguator: Option<String>,
    ) -> Result<QueueStatus, BroccoliError> {
        self.broker
            .get_queue_status(queue_name, disambiguator)
            .await
            .map_err(|e| BroccoliError::QueueStatus(format!("Failed to get queue status: {e:?}")))
    }
}