Function queue_dequeue

src/server/services/protocols.rs:498–506

(
    from: &str,
    to: &str,
    topic: Option<&str>,
)

}

pub async fn queue_dequeue(
    from: &str,
    to: &str,
    topic: Option<&str>,
) -> Option<ProtocolMessage> {
    let key = queue_key(from, to, topic);
    let mut qs = queues().lock().await;
    qs.get_mut(&key)?.pop_front()
}

pub async fn queue_peek(
    from: &str,