Mosquito
Mosquito
And I think that's it: ```python def main() -> None: connection = await aio_pika.connect() async with connection: channel = await connection.channel() ... asyncio.run(main()) ```
Actually, `__del__` [creates the asyncio task with `.close()`](https://github.com/mosquito/aio-pika/blob/master/aio_pika/connection.py#L223), but it's not a guarantee, cause event loop might be closed before.
So. Today I try to reproduce it. So, the consumer successfully connected after the rabbitmq container restart. Is it still actual? BTW: running the rabbitmq in docker image it is...
In aio-pika>=7 reconnect completely fixed (RobustConnection) as I can see.
Could you provide RabbitMQ traffic dump? Hint command: `tcpdump -w traff.pcap -pni any "port 5672"`
`async with` needs to cancel subscriptions when break.
@przemyslawfierek-silvair thank you for your contribution. Please be patient, I have been allowing the execution of the test, but I am unlikely to be able to merge it in the...
just add `async with message.process(requeue=True, ignore_processed=True), ...:`
Is it reproducing in version 7.0.1?
This fix will work well, however it doesn't seem to solve the original problem. The fact that the set changes at the time of recovery is very strange. The resulting...