lapin
lapin copied to clipboard
amqp-rs
AMQP client library in Rust, with a clean, futures based API
According to the AMQP 0.9.1 docs (https://www.rabbitmq.com/docs/publishers#message-properties), there's a message property called "type". I'm currently integrating against a 3rd party provider that requires this property for routing. It seems though,...
Hello, I would like to limit the number of spawn thread when using tokio executor. I end up using ```rust let semaphore = Arc::new(Semaphore::new(32)); consumer.set_delegate(move |delivery: DeliveryResult| { let semaphore_clone...
Hi, this might be connected to #389 but my issue is that the process hangs instead of returning error on the operation (instead of not reconnecting on shutdown), let me...
Hi, I successfully integrated lapin with the tokio runtime but I noticed it was still pulling 2 different versions of async-io. Is there a way to make that optional? ```...
I'm using Redis as my broker in one of my project. So is there a way to use lapin with Redis as the broker?
One more step towards #312 The test example in `examples/t.rs` works fine. We publish one message, make the channel get closed by declaring a non existing queue passively, then manage...
I have built a web-app using axum&tokio that creates a new green thread per request. I'm using lapin for RPC with RabbitMQ over a **single** channel which seems to work....
