Struct Config 

pub struct Config<E, R>
where
    E: FullExecutor,
    R: Reactor,
{
    pub name: String,
    pub address: Vec<String>,
    pub reconnect_delay: Duration,
    pub executor: Arc<E>,
    pub reactor: Arc<R>,
}

Configuration for the rabbitmq connection

Fields

name: String

address: Vec<String>

reconnect_delay: Duration

executor: Arc<E>

reactor: Arc<R>

Implementations

impl<E, R> Config<E, R>

where E: FullExecutor, R: Reactor,

pub fn new<I: Display, T: Iterator<Item = I>>( name: String, host: T, user: &str, password: &str, reconnect_delay: Duration, executor: E, reactor: R, ) -> Self

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