python - py-amqp / flopsy：Pythonで単一のAMQPメッセージを待機しています

Question

これと同様の質問があります。py-amqp/flopsyでは、「永遠に待つつもりです。メッセージが届くたびにこのコールバックを呼び出したい」と言うのは簡単ですが、見つかりません。 「OK、今すぐ待ちたいメッセージが届きました」という言い方をします。（多分GOTO？冗談です...）これを行うためのエレガントな方法はありますか？

Answer 1

OK、多分これは私には明白だったはずです：あなたがflopsy（amqplibの薄いラッパーです）にコールバックを登録するなら

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

次にraise、例外を使用callback_funcして残りのコードにアクセスできます。

ボーナス質問wait()：応答が受信されない場合の最大タイムアウトを設定するにはどうすればよいですか？unittestこれがテストケースのコンテキストにあるとしましょう。