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
35
36
37
38
39
40
41
42
43

use super::with_chan;
use crate::{ExchangeDeclareOptions, ExchangeType, Publish};

#[test]
fn test_publish_empty() {
    with_chan(|chan| {
        for _ in 0..2 {
            chan.basic_publish("", Publish::new(&[], "does.not.exist"))
                .unwrap();
        }
    })
}

#[test]
fn test_declare() {
    let name = "amiquip-test-declare";

    with_chan(|chan| {
        let ex1 = chan
            .exchange_declare(
                ExchangeType::Direct,
                name,
                ExchangeDeclareOptions::default(),
            )
            .unwrap();
        ex1.publish(Publish::new(&[], "does.not.exist")).unwrap();

        let ex2 = chan
            .exchange_declare_nowait(
                ExchangeType::Direct,
                name,
                ExchangeDeclareOptions::default(),
            )
            .unwrap();
        ex2.publish(Publish::new(&[], "does.not.exist")).unwrap();

        let ex3 = chan.exchange_declare_passive(name).unwrap();
        ex3.publish(Publish::new(&[], "does.not.exist")).unwrap();

        assert_eq!(ex1.name(), ex2.name());
        assert_eq!(ex1.name(), ex3.name());
    })
}