Juan Calderon-Perez
Juan Calderon-Perez
@laurazard Is this still relevant?
This is still happening in v9.4.0 @mosquito Can be reproduce with https://aio-pika.readthedocs.io/en/latest/patterns.html
> @gaby what exactly happening? With using `connect_robust()` if the connection to `RabbitMQ`is lost (**not closed**) the logs show the consumer trying to reconnect every `5 secs`. Once `RabbitMQ` becomes...
@mosquito @Darsstar Issue still happens in v9.4.1 I can post a full example in 1-2 hrs, but basically just restarting the RabbitMQ container causes this. It's a connection lost event...
@mosquito @Darsstar worker.py ```python import asyncio from aio_pika import connect_robust from aio_pika.patterns import Master, NackMessage, RejectMessage async def worker(*, task_id: int) -> None: if task_id % 2 == 0: raise...
@mosquito @Darsstar What I'm getting from this issues is the connection and channel are both re-created and established. The queue is not redeclared and the consumer is not re-created. Is...
@Darsstar That fixed the issue! It now redeclares the queue and starts consuming again. The documentation needs to be updated if the WeakRef are going to be involved.
I have spent +2hrs trying to use this package and still can't figure out how to properly StreamCompress files into tar files. There documentation needs more examples.
@benweissmann @vmihailenco Any updates on this ?
@chayim @vlasky @elena-kolevska Any chance of getting #2076 merged?