2 unstable releases
0.2.0 | Feb 14, 2023 |
---|---|
0.1.0 | Feb 12, 2023 |
#42 in #rabbitmq
689 downloads per month
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