amiquip 0.4.2

Pure Rust RabbitMQ client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

use crate::{Channel, Connection};
use std::env;
use std::sync::Once;

mod exchange;

static PRINT_WARNING: Once = Once::new();

fn with_test_url<F: FnOnce(&str)>(f: F) {
    match env::var("AMIQUIP_TEST_URL") {
        Ok(url) => f(&url),
        Err(env::VarError::NotPresent) => PRINT_WARNING.call_once(|| {
            println!("AMIQUIP_TEST_URL not defined - skipping integration tests");
        }),
        Err(env::VarError::NotUnicode(_)) => {
            panic!("AMIQUIP_TEST_URL exists but is not valid unicode")
        }
    }
}

fn with_conn<F: FnOnce(&mut Connection)>(f: F) {
    with_test_url(|url| {
        let mut conn = Connection::insecure_open(url).unwrap();
        f(&mut conn);
        conn.close().unwrap();
    })
}

fn with_chan<F: FnOnce(&Channel)>(f: F) {
    with_conn(|conn| {
        let chan = conn.open_channel(None).unwrap();
        f(&chan)
    })
}