28 releases (5 stable)
Uses new Rust 2021
2.0.0 | Feb 2, 2022 |
---|---|
1.1.0 | Jan 30, 2022 |
1.0.0 | Dec 23, 2020 |
0.3.1 | Nov 21, 2020 |
0.1.3 | Jun 26, 2020 |
#5 in #amqp0-9-1
6,986 downloads per month
Used in 13 crates
(12 directly)
335KB
9K
SLoC
Lapin integration with tokio
This crate integrates lapin with tokio by using tokio's executor inside of lapin for its internal operations and for consumer delegates.
use tokio_amqp::*;
use lapin::{Connection, ConnectionProperties, Result};
use std::sync::Arc;
use tokio::runtime::Runtime;
async fn tokio_main() -> Result<()> {
let addr = std::env::var("AMQP_ADDR").unwrap_or_else(|_| "amqp://127.0.0.1:5672/%2f".into());
let conn = Connection::connect(&addr, ConnectionProperties::default().with_tokio()).await?; // Note the `with_tokio()` here
let channel = conn.create_channel().await?;
// Rest of your program
}
fn main() {
let rt = Runtime::new().expect("failed to create runtime");
rt.block_on(tokio_main()).expect("error");
}
Dependencies
~7–14MB
~268K SLoC