私はメッセージ ブローカーを初めて使用し、問題を抱えています。
私がする必要があるのはこれです。メッセージ que を確認します。メッセージ キューがバックアップされている場合は、一度に 1 つのメッセージを 7 秒ごとに解放する必要があります。どこから始めればよいかわからない。
1 に答える
0
ここでのリリースとはどういう意味ですか? そのメッセージを消費したいだけですか、それとも何らかの障害キューに入れたいですか?
その場合、Timeout Control ノードを使用して 7 秒ごとにフローを駆動し、MQGET ノードを使用してメッセージを消費できます (オプションで、MQOutput ノードを接続してメッセージを別のキューに入れます)。
注意が必要なのは、キューがバックアップされているかどうかを判断することです。Java Compute Node を使用し、PCF を使用して MQ Java Base API を使用して呼び出しを行い、キューの深さを確認します。
キューの深さが特定のしきい値を超えている場合、フローは MQGET ノードまでしか伝播しませんでした。
API ドキュメントから PCF クラスの使用に関する詳細情報を取得できます。
于 2013-09-19T16:38:21.420 に答える