集約ファンイン・フローは、ファンアウト・フローにより送信された要求メッセージへの応答を受信し、受信されたすべての応答を含む結合された応答メッセージを構成します。
始める前に:
同じメッセージ・フロー内にファンアウトおよびファンイン・フローを組み込むことは可能です。ただし、2 つの別々のフローを作成してもかまいません。 別個のメッセージ・フローを構成することの利点について詳しくは、ファンアウトおよびファンイン集約フローの関連付けを参照してください。同じファンイン・フローの複数のコピーを同じ実行グループまたは別の実行グループ内にデプロイしないでください。
ファンアウト・フローをトランザクションに構成しない場合は、指定したタイムアウト値が原因で、結合された応答メッセージが、すべての応答がファンイン・フローによって受信される前に生成されることもあります。 詳しくは、集約ファンアウト・フローの作成を参照してください。
サンプルに関する情報は、WebSphere® Message Broker Toolkit に統合されているインフォメーション・センター、またはオンライン・インフォメーション・センターを使用する場合にのみ表示できます。 サンプルは、WebSphere Message Broker Toolkit に統合されているインフォメーション・センターを使用する場合にのみ実行できます。
ファンイン・フローを作成するには、以下のようにします。
AggregateReply ノードは、 ComIbmAggregateReplyBody と呼ばれる Root の下の結合メッセージ・ツリー内にフォルダーを作成します。 ノードは、このフォルダーの下に、AggregateRequest ノードで設定した名前を使用して、いくつかのサブフォルダーを作成します。 これらのサブフォルダーには、関連する応答メッセージが読み込まれます。
例えば、要求メッセージが次のフォルダー名を持つとします。
結果として AggregateReply ノードによって作成される集約応答メッセージは、以下の例と同様の構造を持つことになります。
Compute ノード内の ESQL を使用して、 タクシー会社からの応答にアクセスするには、次の相関名を使用します。
InputRoot.ComIbmAggregateReplyBody.TAXI.xyz
フォルダー名は固有でなくてかまいません。 フォルダー名が TAXI の要求が複数ある場合、配列添え字表記法を使用して個々の応答にアクセスできます。以下に例を示します。
InputRoot.ComIbmAggregateReplyBody.TAXI[1].xyz
InputRoot.ComIbmAggregateReplyBody.TAXI[2].xyz