Class BroccoliQueue

src/queue.rs:407–414

Main queue interface for interacting with the message broker. `BroccoliQueue` provides methods for publishing and consuming messages, as well as processing messages with custom handlers.

/// `BroccoliQueue` provides methods for publishing and consuming messages,
/// as well as processing messages with custom handlers.
pub struct BroccoliQueue {
    /// The underlying message broker implementation
    #[cfg(not(feature = "management"))]
    broker: Arc<Box<dyn Broker>>,

    #[cfg(feature = "management")]
    broker: Arc<Box<dyn BrokerWithManagement>>,
}

impl Clone for BroccoliQueue {
    fn clone(&self) -> Self {