aio-pika
aio-pika copied to clipboard
mosquito
AMQP 0.9 client designed for asyncio and humans.
Is it ok that `robust_connection `with args `reconnection_interval=0.5 `and `timeout=2` throws exception when connection couldn't be re-established during `exchange.publish(Message(...))`? ``` RuntimeError: Writer is None Task exception was never retrieved future:...
Hi, I'm working with a project where I have to work with **Python 3.5**, no choice there. And the maximum available version for Python 3.5 is **aio-pika 6.8.2** Using aio-pika,...
Example： ```python ... async with message.process(requeue=True, ignore_processed=True): a = 1 / 0 ``` Do I put the message back into the queue when I try an exception
Found in Version: 6.7.1 `RobustConnection.add_reconnect_callback` expects a callback function with two parameters, else on each reconnect this error is logged: ``` ERROR - 2020-11-20 11:34:27,397 - tools.py - 168 -...
Hi, I met the problem, when I used the Pool class for channel, if in some one from them arise error, and it got back into pool, next time it...
This patch fixes problem with unexpected restoration already closed channels (after reconnect to the AMQP broker) when the `RobustConnection` is being used. The problem is caused by the not freeing...
JsonRPC is throwing and error `encoding error "string argument without an encoding"` without this fix. It's probably a leftover from Python 2
After switching from `pika` to `Kombu` and then to `aio-pika` I've discovered that `aio-pika` doesn't properly supported nested dicts inside headers like the other 2 libraries. Supporting it was quite...
Added support of str type for Message body argument like in original `pika` module. change Now Message body can be str or bytes or raise TypeError. Previous implementation `body if...
