foxtive 0.25.6

Foxtive Framework
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

use lapin::ConnectionProperties;

pub use deadpool::managed::QueueMode;
pub use deadpool_lapin::{PoolConfig, Timeouts};

pub struct RabbitmqConfig {
    pub(crate) dsn: String,
    pub(crate) pool_config: PoolConfig,
    pub(crate) conn_props: ConnectionProperties,
}

impl RabbitmqConfig {
    pub fn create(dsn: &str) -> Self {
        Self {
            dsn: dsn.to_string(),
            pool_config: PoolConfig::default(),
            conn_props: ConnectionProperties::default(),
        }
    }

    pub fn conn_props(mut self, conn_props: ConnectionProperties) -> Self {
        self.conn_props = conn_props;
        self
    }

    pub fn pool_config(mut self, pool_config: PoolConfig) -> Self {
        self.pool_config = pool_config;
        self
    }
}