【发布时间】:2015-09-26 16:39:16
【问题描述】:
我正在使用here 显示的方法,如下所示:while method_frame is None:
method_frame, header_frame, method_frame= channel.basic.get("test_queue)
看起来这种轮询方式不是那么有效,因为如果队列为空,基本 get 也可以工作,并带来空消息。
我需要一种只接收一条消息的逻辑,只有当我有机会处理它时,这就是我选择basic.get 而不是basic.consume 的原因。
是否有人有想法通过使用某些 pika 库的其他机制来进行更有效的轮询?
【问题讨论】: