集約ファンイン・フローは、ファンアウト・フローにより送信された要求メッセージへの応答を受信し、 受信されたすべての応答を含む結合された応答メッセージを構成します。
始める前に:
このタスクを実行するには、以下のタスクを完了している必要があります。
指定したタイムアウト値によっては、結合された応答メッセージは、 すべての応答がファンイン・フローによって受信される前に生成されることもあります。
ファンイン・フローの例を検討するには、WebSphere Business Integration Message Broker で提供されている 航空機 (Airline) サンプルを参照してください。
ファンイン・フローを作成するには、以下のようにします。
これは、要求/応答モデルをサポートする入力ノードでなければなりません。 要求/応答をサポートする、組み込みノード MQeInput および MQInput、またはユーザー定義の入力ノードあるいはこれらのノードの混合を使用することができます (これらの応答を送信するアプリケーションの要件に応じて異なります)。 それぞれの入力ノードによって受信された応答は、 対応する要求と同じプロトコルを介して送信されなければなりません (たとえば、 ファンアウト・フロー内に MQOutput ノードを組み込む場合には、 その要求への応答は、このフロー内の MQInput ノードによって受信されなければなりません)。
これは、最も単純な構成を表します。 適当であれば、入力ノードと AggregateReply ノードとの間に他のノードを組み込むことができます。 たとえば、監査のために応答を (Warehouse ノードに) 保管したい場合もあります。
集約要求の特定のグループに対するすべての応答が収集されると、AggregateReply ノードは、集約された応答メッセージを作成し、out ターミナルを介して集約された応答メッセージを伝搬します。
また、AggregateReply ノードは、 ファンアウト・フロー上の対応する AggregateControl ノードによって送信された (ファンアウトおよびファンイン集約フローの関連付けで説明されているとおり、直接または間接的に) 制御メッセージを制御ターミナル上に受信します。 この制御メッセージの内容を変更しないでください。
out ターミナルを介して伝搬される集約された応答メッセージの構造、 およびメッセージの内容へのアクセス方法に関する情報は、 結合メッセージの内容へのアクセスで提供されています。
AggregateReply ノードは、ComIbmAggregateReplyBody と呼ばれる Root の下の結合メッセージ・ツリー内にフォルダーを作成します。 この下に、AggregateRequest ノードで設定したフォルダー名を使用する、いくつかのフォルダーを作成します。 関連した応答メッセージは、その下に置かれます。
たとえば、要求メッセージが次のフォルダー名を持つとします。
結果として AggregateReply ノードによって作成される集約応答メッセージは、以下に示すような構造を持つことになります。
Compute ノードを使用して、タクシー会社からの応答にアクセスするには、次の相関名を使用します。
InputRoot.ComIbmAggregateReplyBody.TAXI.xyz
フォルダー名は固有でなくてかまいません。 フォルダー名が TAXI の要求が複数ある場合、配列添え字表記法を使用して個々の応答にアクセスできます。以下に例を示します。
InputRoot.ComIbmAggregateReplyBody.TAXI[1].xyz InputRoot.ComIbmAggregateReplyBody.TAXI[2].xyz
関連概念
メッセージ・フロー
メッセージ・フローの集約
ユーザー定義の入力ノード
ユーザー定義の出力ノード
関連タスク
集約フローの構成
集約ファンアウト・フローの作成
ファンアウトおよびファンイン集約フローの関連付け
集約のタイムアウトの設定
複数の AggregateControl ノードの使用
集約フロー内の例外およびデータベース・デッドロックの処理
メッセージ・フローの設計
メッセージ・フローの作成
メッセージ・フローの内容の定義
ユーザー定義拡張機能の開発
関連資料
AggregateControl ノード
AggregateReply ノード
AggregateRequest ノード
Compute ノード
MQeInput ノード
MQeOutput ノード
MQInput ノード
MQOutput ノード
注意 |
商標 |
ダウンロード |
ライブラリー |
技術サポート |
フィードバック
![]() ![]() |
ac12300_ |