tokio-amqp

library2.0.0rscratesunverified

lapin integration with tokio

# Cargo.toml
[dependencies]
tokio-amqp = "2.0.0"

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · TOKIO-AMQP

tokio-amqp

messagingrustv2.0.0

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

LapinTokioExt

✓ use tokio_amqp::LapinTokioExt;

Connects to an AMQP broker using lapin with tokio runtime.

use tokio_amqp::LapinTokioExt; #[tokio::main] async fn main() { let conn = lapin::Connection::connect("amqp://localhost", Default::default()).await.unwrap(); println!("Connected to AMQP"); }

Debug

Known issues

gotchaRequires tokio runtime to be active

fix

Use #[tokio::main] or manually create a tokio runtime

affects: >=1.0.0

Upgrade

Version history

2.0.0latest on crates.io

Audit

Dependencies

No dependency data recorded yet.

Agent activity

30 hits · last 30 days

node

Amazon

Resources

githubhttps://github.com/amqp-rs/lapin ↗

homepagehttps://github.com/amqp-rs/lapin ↗

docshttps://docs.rs/tokio-amqp/ ↗