python - py-amqp/flopsy：在 Python 中等待单个 AMQP 消息

Question

我有一个与此类似的问题：在 py-amqp/flopsy 中很容易说“我将永远等待，并且我希望在收到消息时调用此回调”，但我找不到任何方式说“好的，我收到了我想要的消息，现在停止等待。” （也许是 GOTO？开个玩笑......）有没有一种优雅的方式来做到这一点？

Answer 1

好的，也许这对我来说应该很明显：如果您在 flopsy 中注册一个回调（这是 amqplib 的一个薄包装器）

consumer.register('kind', callback_func)
consumer.wait()
# more code goes here...

然后您可以raise输入异常callback_func以获取其余代码。

奖励问题wait()：如果从未收到响应，如何设置最大超时？假设这是在unittest测试用例的上下文中。