// use std::time::Duration;
// use mitoo::RabbitMQUtil;


#[tokio::main]
async fn main() {
    // // https://github.com/gftea/amqprs/blob/main/examples/src/basic_pub_sub.rs
    // let util = RabbitMQUtil::new("192.168.1.187", 5672, "guest", "guest").await;
    // util.consume("hello", |basic_properties, content| async move {
    //     println!("===============>{}", String::from_utf8(content).unwrap());
    //     println!("===============>{:?}", basic_properties);
    // }).await;
    // tokio::time::sleep(Duration::from_secs(15)).await;
}
