2

kombuモジュールを使用してRabbitMQメッセージサーバーと通信するTwistedアプリケーション(Python 2.7)があります。

heartbeat_check()接続(おそらくファイアウォール関連)を閉じる際に問題が発生しており、これを処理するメソッドを実装しようとしています。接続にハートビート値10が設定されており、5秒ごとLoopingCallにメソッドを呼び出すTwistedがあります。heartbeat_check(rate=2)

ただし、問題が発生すると、他のすべての呼び出しで例外がスローされます(呼び出しを含むheartbeat_check()関数で取得したログ情報に基づいて)。私は心拍数と心拍数の値のあらゆる種類のバリエーションを試しましたが、何も役に立たないようです。デバッグすると、マイナーなメッセージトラフィックが送受信されているように見えますが、メッセージコンシューマーでそれに応答する必要がありますか?LoopingCallheartbeat_checkheartbeat_call()

事前に感謝します、どんなヒントやポインタも非常に役に立ちます!!

ダグ

4

0 に答える 0