py-amqp/flopsy：在Python中等待一個AMQP消息

Question

我有一個和this one類似的問題：在py-amqp/flopsy中很容易說「我將永遠等待，並且我想要這個回調每當有消息進來時都會被調用「，但我找不到任何方式說」好吧，我收到了我想要的消息，現在停止等待。「 （也許GOTO？只是在開玩笑...）有沒有這樣做的優雅方式？

Answer 1

OK，也許這應該是很明顯對我說：如果你有

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

那麼你可以raise在callback_func的異常去登記flopsy回調（這大約是amqplib瘦包裝）代碼的其餘部分。

紅利問題：如何在不收到回覆的情況下爲wait()設置最大超時時間？假設這是在unittest測試用例的背景下。