pub async fn purge_queue( broker_url: &str, queue: &str, confirm: bool, ) -> Result<()>
Purge all tasks from a queue