#rabbitmq

deadpool-amqprs

Dead simple async pool for amqprs

2 unstable releases

0.2.0 Feb 14, 2023
0.1.0 Feb 12, 2023

#42 in #rabbitmq

Download history 147/week @ 2024-07-12 55/week @ 2024-07-19 97/week @ 2024-07-26 152/week @ 2024-08-02 193/week @ 2024-08-09 197/week @ 2024-08-16 86/week @ 2024-08-23 97/week @ 2024-08-30 353/week @ 2024-09-06 167/week @ 2024-09-13 249/week @ 2024-09-20 276/week @ 2024-09-27 85/week @ 2024-10-04 423/week @ 2024-10-11 121/week @ 2024-10-18 1/week @ 2024-10-25

689 downloads per month

MIT license

7KB
91 lines

deadpool-amqprs

Deadpool for amqprs

Deadpool is a dead simple async pool for connections and objects of any type.

This crate implements a deadpool manager for amqprs.

Example

use deadpool_amqprs::Config;
use amqprs::{callbacks::{DefaultChannelCallback, DefaultConnectionCallback}, connection::OpenConnectionArguments};

#[tokio::main]
async fn main() {
    let config = Config::new_with_con_args(OpenConnectionArguments::default());
    let pool = config.create_pool();
    
    let con = pool.get().await.unwrap();
    con.register_callback(DefaultConnectionCallback).await.unwrap();

    let channel = con.open_channel().await.unwrap();
    channel.register_callback(DefaultChannelCallback).await.unwrap();

    // Do stuff with `channel`.
}

Dependencies

~3–12MB
~128K SLoC