Mosquito
Mosquito
* `wireshark` on local machine * `tcpdump -pni any port 5672` on remote through the ssh
As far as I understand, you are not reading the documentation for this library, and of course, in the another implementation may be another default. You can use [`queue.consume(..., no_ack=True)`](https://aio-pika.readthedocs.io/en/latest/apidoc.html#aio_pika.Queue.consume)...
"Message acknowledgments are turned on by default" - means you have to send acknowledgment by default.
I did the maximum to not change the code that is used in the tests. Therefore, in most cases everything should be fine. But just in case, here is a...
@ancalita The problem was at the intersection of aiormq and aio_pika, and was almost completely fixed in branch 9. Backporting this to branch 8, I don't have the resources, sorry....
@ancalita the 9.0.5 is really better with it. But the latest bulk of fixes in #533
The AMQP protocol is designed in such a way that the connection should be open for as long as possible. However, if your task is to periodically process accumulated messages,...
Thanks to @aozupek the problem is resolved and a new fixed version released as [aio-pika==9.2.3](https://pypi.org/project/aio-pika/9.2.3/)
For local development you can update the poetry version in virtualenv for example. If you need to install an already built package, it is available on pypi with a generated...
AMQP 0.9.x protocol is not provide something like this. The get_queue method is a syntax sugar for declaring queue with a passive flag