lapin
lapin copied to clipboard
amqp-rs
AMQP client library in Rust, with a clean, futures based API
[Connection::on_error](https://docs.rs/lapin/latest/lapin/struct.Connection.html#method.on_error) in its current implementation doesn't catch channel errors. Perhaps this is working as intended, however there is no equivalent for catching errors on a channel, for example through a...
I am trying to use `select! { delivery = consumer.next(), other future => ... }` to fetch new messages. I have tried it, and it worked like a charm. However,...
Hello there, I implemented an application that uses lapin to purely publish messages. It is used as a cronjob that will spawn many tens of threads concurrently and for each...
I've been using this library and recently I've noticed that when using a Delegate, memory seems to leak. I have the following Minimum Reproducible Example where if you run this...
Hi, We have experienced some issues with one of our providers killing their services every once in a while, which results in Lapin to stop consuming messages. We have an...
On Windows, I'm getting the following error log when creating a connection and channel in lapin, using it to publish and receive some messages and then letting the program reach...
Hello, I've been using this repository and find it very useful. However, I've noticed that the documentation could be improved to better assist those not very familiar with Rabbitmq Specifically,...
I'm looking for any information that will help me connect to my Amazon MQ RabbitMQ instance. You have to use TLS to connect to these instances. I plan on deploying...
