bb8-lapin 0.8.1

r2d2-lapin, but for async tokio based connections
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use async_rs::Runtime;
use bb8_lapin::prelude::*;

#[tokio::main]
async fn main() {
    let amqp_url = std::env::var("TEST_AMQP_URL").unwrap_or_else(|_| "amqp://guest:guest@127.0.0.1:5672//".to_string());

    let builder = ConnectionBuilder::new_with_runtime(Runtime::tokio_current()).with_uri_str(amqp_url);
    let manager = LapinConnectionManager::new(builder);
    let pool = bb8::Pool::builder().max_size(15).build(manager).await.unwrap();

    for _ in 0..20 {
        let pool = pool.clone();
        tokio::spawn(async move {
            let _conn = pool.get().await.unwrap();
            // use the connection
            // it will be returned to the pool when it falls out of scope.
        });
    }
}