Mosquito
Mosquito
https://docs.python.org/3/library/asyncio-dev.html#running-blocking-code See this article for more information
@aoaostar This is not a recovery method, it is a way to run blocking code in ANY place that uses asyncio.
@drsnyder did you try to upgrade to the latest release?
Current version is https://pypi.org/project/aio-pika/9.5.4/
Thank you for your contribution. I have merge this but I have to little bit modify this code for passing an exception to closing future. See more to #218
This is the error from the kernel https://github.com/mosquito/caio/blob/master/caio/linux_aio.c#L198-L201 The difference between versions is the https://github.com/mosquito/caio/pull/17/files this change creates and after destroy the temporary context in import time. Please double check...
Don't you want create a PR :-)
Set lower heartbeat and server will be forget about lost client faster.
@decaz what do you think?
When queue is empty an exception `aio_pika.exceptions.QueueEmpty` raising. That's because AMQP server respond instantly. But when you try to set `prefetch_count=1` on the channel, and you will try to get...