rabbit-auto 0.7.0

Wrappers for lapin publishers and consumers
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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

//! Configuration for the rabbitmq connection.
//!
//!
use std::fmt::Display;
use std::time::Duration;

/// Configuration for the rabbitmq connection
pub struct Config {
    pub name: String,
    pub address: Vec<String>,
    pub reconnect_delay: Duration,
}

impl Config {
    /// Creates a new configuration
    /// # Arguments:
    /// * host - the address to rabbitmq server
    /// * user - user login name
    /// * password - user login password
    /// * sleep_duration - duration of the sleep before trying reconnect again to the rabbitmq server
    pub fn new<I: Display, T: Iterator<Item = I>>(
        name: String,
        host: T,
        user: &str,
        password: &str,
        reconnect_delay: Duration,
    ) -> Self {
        let mut address = Vec::new();
        for addr in host {
            let addr = format!("amqp://{}:{}@{}/%2f", user, password, addr);
            address.push(addr);
        }
        Self {
            name,
            address,
            reconnect_delay,
        }
    }
}

// impl Config {
//     /// Creates a new configuration
//     /// # Arguments:
//     /// * host - the address to rabbitmq server
//     /// * user - user login name
//     /// * password - user login password
//     /// * sleep_duration - duration of the sleep before trying reconnect again to the rabbitmq server
//     pub fn new<I: Display, T: Iterator<Item = I>>(
//         name: String,
//         host: T,
//         user: &str,
//         password: &str,
//         reconnect_delay: Duration,
//     ) -> Self {
//         let mut address = Vec::new();
//         for addr in host {
//             let addr = format!("amqp://{}:{}@{}/%2f", user, password, addr);
//             address.push(addr);
//         }
//         Self {
//             name,
//             address,
//             reconnect_delay,
//         }
//     }
// }