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...

您可以在 callback_func 中引发异常获取代码的其余部分。

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