rustium 0.1.4

A Rust application framework that values concurrency, performance, and scalability
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

use amqprs::connection::{Connection, OpenConnectionArguments};
use di::injectable;

use crate::{datastore::imq_dal::IMqDal, prelude::*, settings::rabbit::RabbitSettings};

// region: Structs

#[injectable(IMqDal)]
pub struct RabbitDAL {
    pub con: Option<Connection>,
}
// endregion: Structs

// region: Implementation

impl IMqDal for RabbitDAL {}
impl Default for RabbitDAL {
    fn default() -> Self {
        Self { con: Option::None }
    }
}

impl RabbitDAL {
    pub async fn new(conf: RabbitSettings) -> RustiumResult<Self> {
        let con = Connection::open(&OpenConnectionArguments::new(
            &conf.server,
            conf.port.into(),
            &conf.username,
            &conf.password,
        ))
        .await?;

        Ok(Self { con: Some(con) })
    }
}
// endregion: Implementation