kombuモジュールを使用してRabbitMQメッセージサーバーと通信するTwistedアプリケーション(Python 2.7)があります。
heartbeat_check()
接続(おそらくファイアウォール関連)を閉じる際に問題が発生しており、これを処理するメソッドを実装しようとしています。接続にハートビート値10が設定されており、5秒ごとLoopingCall
にメソッドを呼び出すTwistedがあります。heartbeat_check(rate=2)
ただし、問題が発生すると、他のすべての呼び出しで例外がスローされます(呼び出しを含むheartbeat_check()
関数で取得したログ情報に基づいて)。私は心拍数と心拍数の値のあらゆる種類のバリエーションを試しましたが、何も役に立たないようです。デバッグすると、マイナーなメッセージトラフィックが送受信されているように見えますが、メッセージコンシューマーでそれに応答する必要がありますか?LoopingCall
heartbeat_check
heartbeat_call()
事前に感謝します、どんなヒントやポインタも非常に役に立ちます!!
ダグ