使用pika.BlockingConnection，我想使用队列中的消息然后退出

Question

我已经使用pika.BlockingConnection和channel.start_using（）编写了一个使用者，该使用者使用来自特定队列的消息，当消息从队列中耗尽时，该使用者无限期地等待下一条消息。

有没有一种方法可以指定某种超时时间，如果在特定时间段内使用者没有从队列中提取任何消息，则start_using（）可以正常退出。

我正在使用python 3.7.4和pika 1.1.0从RabbitMQ 3.7.12中使用。

Answer 1

将"consume generator"用于超时。

---

_{[NOTE： RabbitMQ团队监视rabbitmq-users mailing list，并且有时仅在StackOverflow上回答问题。}