メイン・メッセージ・フローの作成

Error Handler サンプルのメイン・メッセージ・フローが提供されていますが、 メッセージ・フローを独自に作成したい場合は、次のようにします。 メイン・メッセージ・フローを作成するには、事前にエラー処理サブフローを作成する必要があります。エラー処理サブフローの作成を参照してください。

  1. サブフロー作成時に作成された Error Handler Message Flows メッセージ・ブローカー・プロジェクトの中に、Main_Flow という名前の新しいメッセージ・フローを作成します。
    手順については、WebSphere Message Broker 資料の メッセージ・フローの作成を参照してください。
  2. メッセージ・フロー・エディターで、次の表にリストされているノードを追加して名前変更します。
    手順については、WebSphere Message Broker 資料の メッセージ・フロー・ノードの追加を参照してください。
    パレット・ドロワー ノード・タイプ ノード名
    WebSphere MQ MQInput STAFF_IN
    WebSphere MQ MQOutput STAFF_FAIL
    Routing Filter Check Valid Staff Number
    Database Database Update Staff Database
    Construction Throw Throw
    WebSphere MQ MQOutput STAFF_OUT
  3. サブフローをメイン・メッセージ・フローに追加します。
    1. Main_Flow.msgflow ファイルが、メッセージ・フロー・エディターに表示されたことを確認してください。
    2. メッセージ・フロー・エディターを右クリックして、「サブフローの追加」をクリックします。 「サブフローの追加」ウィンドウが開きます。
    3. 「サブフローの追加」ウィンドウで、「Error Handler Message Flows」プロジェクトを 展開し、次に「(デフォルト)」を展開して、 サブフロー・ファイルである「Error_Handler.msgflow」をクリックします。 「OK」をクリックします。
    4. サブフローを表す Error_Handler という名前のノードが、メッセージ・フロー・エディターに追加されます。
  4. 次の表に示されているように、ノードを接続します。
    手順については、WebSphere Message Broker 資料の メッセージ・フロー・ノードの接続を参照してください。
    ノードが正しく接続されたかどうかを確認するには、Error Handler サンプルについての図を 参照してください。
    ノード名 ターミナル 接続先のノード
    STAFF_IN Out Error_Handler
    Failure STAFF_FAIL
    Error Handler Out Check Valid Staff Number
    Check Valid Staff Number False Throw
    True Update Staff Database
    Update Staff Database Out STAFF_OUT
    Failure STAFF_OUT
  5. 次の表に示されているように、ノードのプロパティーを構成します。この表に代替値が示されていなければ、すべてのプロパティーに関してデフォルト値を受け入れます。
    手順については、WebSphere Message Broker 資料の メッセージ・フロー・ノードの構成を参照してください。
    ノード名 ページ プロパティー
    STAFF_IN 基本 キュー名 STAFF_IN
    入力メッセージ構文解析 メッセージ・ドメイン XML : XML メッセージ用
    STAFF_FAIL 基本 キュー名 STAFF_FAIL
    拡張 トランザクション・モード Yes
    Update Staff Database 基本 データ・ソース STAFFDB
    Throw 基本 メッセージ番号 3001
    基本 メッセージ・テキスト 無効スタッフ番号
    STAFF_OUT 基本 キュー名 STAFF_OUT
    拡張 トランザクション・モード Yes
  6. 「Error Handler Message Flows」プロジェクトで、「Main_Flow.esql」ファイルをダブルクリックして、ESQL エディターで開きます。以下の ESQL コード・モジュールを ESQL ファイルにコピー、および貼り付けし、ファイルを保存します。詳しくは、WebSphere Message Broker 資料の ESQL の開発を参照してください。
    CREATE FILTER MODULE Main_Flow_Filter
       CREATE FUNCTION Main() RETURNS BOOLEAN
          BEGIN
       If Body.Staff.StaffNumber<='10' THEN
          RETURN TRUE;
          ELSE
          RETURN FALSE;
       END IF;
       END;
    END MODULE;
    
    CREATE DATABASE MODULE Main_Flow_Database
       CREATE FUNCTION Main() RETURNS BOOLEAN
       BEGIN
       INSERT INTO Database.STAFF(STAFFNUM, LASTCHANGE, FIRSTNAME, LASTNAME)
       VALUES(Body.Staff.StaffNumber, CURRENT_TIMESTAMP, 
       Body.Staff.NameInfo.FirstName, Body.Staff.NameInfo.LastName); 
       RETURN TRUE;
       END;
    END MODULE;
  7. メッセージ・フローを保存します。

Error Handler サンプルの作成に戻る