mosquito / aio-pika

AMQP 0.9 client designed for asyncio and humans.
https://aio-pika.readthedocs.org/
Apache License 2.0
1.18k stars 186 forks source link

`QueueIterator` doesn't raise errors when Queue was deleted #612

Closed mdczaplicki closed 5 months ago

mdczaplicki commented 5 months ago

I've encountered a situation in which we've manually deleted a Queue using RabbitMQ dashboard and a running consumer didn't raise any errors.

We:

  1. Get channel from connection
  2. Declare exchange
  3. Declare queue
  4. Async iterate queue.iterator()

When we delete the queue manually during point 4 - the consumer sits idle, it doesn't raise any errors.

mdczaplicki commented 5 months ago

It'd duplicated: https://github.com/mosquito/aio-pika/issues/379