Блокировка get aio_pika

Question

Я ожидал, что

await queue.get() 

будет блокироваться в aio_pika, но даже если я не установил параметр тайм-аута, я сразу получаю ошибку:

aio_pika.exceptions.QueueEmpty

В любом случае, чтобы получить блокировку в aio_pika?

РЕДАКТИРОВАТЬ: Это лучшее, что я мог придумать до сих пор.

   while True:
        msg = await q.get(fail=False)
        if msg:
            break
        await asyncio.sleep(1)

Answer 1

Команда RabbitMQ отслеживает список рассылки rabbitmq-users и только иногда отвечает на вопросы по StackOverflow.

---

Вы должны использовать очень большой тайм-аут, согласно документация для этого метода .Кажется, нет другого способа сделать это.