Petr Šebek
Petr Šebek
Yes, it works in version `0.2.5`, thank you for the swift reaction.
Thank you @michaelklishin for pointing me to the `Erlang - Distribution` dashboard. And thank you @gerhard for taking care of this issue. I was working only with `RabbitMQ - Overview`...
I tried the reproduction code with `aiormq==2.7.2` recommended https://github.com/mosquito/aio-pika/issues/112#issuecomment-519597738 here. And it now fails with another exception. Consumer: ``` Traceback (most recent call last): File "/home/artimi/.virtualenvs/rabbit-messaging/lib/python3.6/site-packages/aiormq/base.py", line 25, in __inner...
In version `aio-pika==6.1.3` I am able to achieve robust connection by catching connection exception raised from `publish` and using long-lived consumers (called with `consume` not with `get`). I tested it...
Just for records I experienced this when due to a failure in my program I did not acked a message. 30 minutes after that I could see this in RabbitMQ:...
Thanks for the fix. However, I have an issue with this: I wanted to send nanoseconds since epoch (e.g. 1559224445019561728) because we are using nanoseconds everywhere (we come from a...
I tried to work around this by sending the timestamp in headers. It works but it is complicated because I have to update every producer in our infrastructure before I...
Ok, so I decided to bypass every check in `aio_pika` and `pamqp` and it seems to work. It is just a hack but I have no other option. ```python import...
I haven't tried it but from the brief look at the [pamqp code](https://github.com/gmr/pamqp/blob/main/pamqp/encode.py#L238) it still seems that you cannot pass any int as a timestamp. Thus it is still not...
Hi @hellysmile, I wanted to ask whether you would accept this PR if I edited your suggestions? Because https://github.com/aio-libs/async_lru/pull/50#issuecomment-400426038 it seems that you don't want this to be in your...