Connect:Direct file transfer サンプルについて

IBM Sterling Connect:Direct file transfer のサンプルは、Connect:Direct ノードを使用して、IBM Sterling Connect:Direct と IBM Integration Bus を併用する方法を示します。 このサンプルでは、以下のタスクを例示します。

このサンプルは、以下のシナリオに基づいています。

小さな銀行の本部 (HQ) は、Winchester および Eastleigh 支店の銀行口座に関する口座振替の情報すべてを毎日認可します。 HQ は口座振替を WebSphere MQ メッセージとして受け取り、単一のバッチ・ファイル内に保存します。 一日の最後の振替が送信されると、各支店は 1 日の終わりメッセージを HQ に送信します。 HQ は、両方の支店から 1 日の終わりメッセージを受け取ると、IBM Sterling Connect:Direct を使用して外部の認可サービス・プロバイダーにバッチ・ファイルを転送し、振替を検査する方法に関する指示も一緒に転送します。認可が行われた後で、HQ は認可された口座振替レコードを新しいバッチ・ファイルで受け取ります。 それから HQ はこのバッチ・ファイルをアーカイブし、認可された口座振替レコードを個々の支店の WebSphere MQ キューに送信します。

SendToauthorizingSystem メッセージ・フローの画面取り。

このシナリオは、続くセクションで説明されている 3 つのメッセージ・フローを用いて実装されます。

HQ は振替を支店から受け取って認可システムに送信する
SendToAuthorisingSystem.msgflow

このメッセージ・フローは、HQ の統合ノード上で稼働し、認可が必要な口座振替を支店から受け取ります。ReplyToQ が口座振替レコードに追加され、バッチ・ファイル内に口座振替レコードが収集されます。その後、IBM Sterling Connect:Direct を使用して、ファイルが外部の認可サービス・プロバイダーへ転送されます。

  1. MQInput ノードは、Winchester 支店または Eastleigh 支店から個別の口座振替レコードを受け取り、各レコードを Compute ノードへ送信します。
  2. Compute ノードは、メッセージが 1 日の終わりメッセージかどうかを検出し、1 日の終わりのメッセージの場合はカウンターを増分します。
  3. このメッセージが 1 日の終わりメッセージでない場合は、Compute ノードは MQMD ヘッダーから ReplyToQ を抽出してレコードに追加します。
  4. Compute ノードがレコードを CDOutput ノードへ送信します。
  5. CDOutput ノードがローカル・ファイル内のすべてのレコードをバッチ処理します。
  6. 両方の支店が 1 日の終わりメッセージを送信した時点で、Compute ノードが CDOutput ノードの Finish File ターミナルにメッセージを送信します。
  7. CDOutput ノードが、バッチ・ファイルを認可サービス・プロバイダーへ転送します。

SendToauthorizingSystem メッセージ・フローの画面取り。

認可サービス・プロバイダーが振替を処理する
AuthorisingSystem.msgflow

このメッセージ・フローは、外部サービス・プロバイダーからの認可システムをエミュレートします。受け取ったバッチ・ファイル内の各口座振替レコードが検査され、認可されて、認可されたレコードが新しいバッチ・ファイル内に収集されます。その後、IBM Sterling Connect:Direct を使用して、ファイルが HQ へ転送されます。

  1. CDInput ノードは HQ から送信されたファイルを受け取ります。
  2. CDInput ノードはバッチ・ファイル内のレコードを解析します。 各レコードは口座振替を表しています。 各レコードが Mapping ノードへ転送されます。
  3. CDInput ノードが、Connect:Direct 転送に含まれているメタデータをローカル環境に取り込みます。
  4. Mapping ノードが、各口座振替レコードを出力メッセージへ移動します。
  5. 認可されたレコードが CDOutput ノードへ送信されます。
  6. CDOutput ノードがローカル・ファイル内のすべてのレコードをバッチ処理します。
  7. CDInput ノードは、バッチ・ファイル内のレコードをすべて処理し終えると、メッセージを End of Data ターミナルから CDOutput ノードの Finish File ターミナルに送信します。
  8. CDOutput ノードが、認可された振替をバッチ・ファイルとして HQ へ転送します。

authorizingSystem メッセージ・フローの画面取り。

HQ は認可された振替を認可システムから受け取って支店に応答する
ReceiveFromAuthorisingSystem.msgflow

このメッセージ・フローは、HQ の IBM Integration Bus 上で稼働し、認可された口座振替をバッチ・ファイル形式で受け取ります。 バッチ・ファイル内の口座振替ごとに、照会を開始した支店に応答します。 初期照会メッセージ内の MQMD ヘッダー内で ReplyToQ として指定された WebSphere MQ キューに、応答が送信されます。

  1. CDInput ノードが、認可されたレコードが含まれたバッチ・ファイルを受け取ります。
  2. CDInput ノードは、バッチ・ファイル内のレコードを解析し、各レコードを MQHeader ノードに送信します。
  3. MQHeader ノードは、各レコードにデフォルトの MQMD ヘッダーを追加してから、Mapping ノードに送信します。
  4. Mapping ノードは ReplyToQ 情報をレコードから MQMD ヘッダーに移動します。
  5. MQReply ノードが、MQMD ヘッダー内の情報を使用して、元の照会を送信した支店へ各レコードを転送します。
  6. CDInput ノードが、受け取ったバッチ・ファイルの名前にタイム・スタンプを付加して、そのバッチ・ファイルをアーカイブします。

ReceiveFromauthorizingSystem メッセージ・フローの画面取り。

サンプルのホームに戻る