Java でのメッセージ処理ノードまたは出力ノードの作成

IBM App Connect Enterprise ツールキットでJavaノードを作成するには、まず新しいJavaプロジェクトを作成する必要があります：

1. 「ファイル」 > 「新規」 > 「プロジェクト」をクリックします。 「Java」 を選択し、 「次へ」をクリックします。
2. 「プロジェクト名」 フィールドにプロジェクトの名前を入力し、 「次へ」をクリックします。
3. 「Java 設定」ペインで、「ライブラリー」タブを選択して、「外部 JAR の追加」をクリックします。
4. install_dir\server\classes\jplugin2.jarを選択します。
5. 「その他」タブのプロンプトに従って、他のビルド設定を定義します。
6. 「完了 (Finish)」 をクリックします。

これで、このプロジェクト内で Java ノードのソースを開発できます。

例えば、メッセージ処理ノード・クラスを宣言するには次のようにします。

package com.ibm.jplugins;

import com.ibm.broker.plugin.*;

public class BasicNode extends MbNode implements MbNodeInterface

IBM App Connect Enterprise ツールキットでクラスを宣言します：

1. 「ファイル」 > 新規 > 「その他」をクリックし、 「クラス」を選択してから、 「次へ」をクリックします。
2. パッケージおよびクラス名フィールドに適切な値を設定します。
3. 「スーパークラス」テキスト・フィールドのテキストを削除し、「参照」をクリックします。
4. MbNode を選択し、 「OK」をクリックします。
5. クリック追加インターフェーステキストフィールドの横にあるボタンをクリックし、 MbNodeInterface。
6. 「完了 (Finish)」 をクリックします。

public MyNode() throws MbException
{
		// create terminals here
		createInputTerminal ("in");
		createOutputTerminal ("out");
		createOutputTerminal ("failure");
}

例えば、組み込みメッセージを含む着信メッセージ・アセンブリーがある場合は、ユーザー定義ノードの evaluate メソッドに次のコードを含めることができます。

1. メッセージ・アセンブリーとその組み込みメッセージの新しいコピーを作成します。

       MbMessage newMsg = new MbMessage(assembly.getMessage());
       MbMessageAssembly newAssembly = new MbMessageAssembly(assembly, newMsg);
   

2. XML メッセージの中の関係のある構文エレメントにナビゲートするには、次のようにします。

       MbElement rootElement = newAssembly.getMessage().getRootElement();
       MbElement switchElement = 
   			rootElement.getFirstElementByPath("/XML/data/action");
   

3. 既存のエレメントの値を変更するには、次のようにします。

     String elementValue = (String)switchElement.getValue();
       if(elementValue.equals("add"))
         switchElement.setValue("change");
       else if(elementValue.equals("change"))
         switchElement.setValue("delete");
       else if(elementValue.equals("delete"))
         switchElement.setValue("hold");
       else
         switchElement.setValue("failure");
   

4. 切り替えタグの子として新しいタグを追加します。

       MbElement tag = switchElement.createElementAsLastChild(MbElement.TYPE_NAME,
                                                              "PreviousValue",
                                                              elementValue);
   

5. この新しいタグに属性を追加します。

       tag.createElementAsFirstChild(MbElement.TYPE_NAME_VALUE,
                                     "NewValue",
                                     switchElement.getValue());
   
       MbOutputTerminal out = getOutputTerminal("out");

変換の一部として、新規メッセージ本体を作成する必要があるかもしれません。 新規メッセージ本体を作成するために、パーサーをメッセージ・ツリー・フォルダーに明確に割り当てる、以下のメソッドのうちの 1 つを使用します。

createElementAfter(String) 
createElementAsFirstChild(String) 
createElementAsLastChild(String) 
createElementBefore(String) 
createElementAsLastChildFromBitstream(byte[], String, String, String, String, int, int, int) 

以下のメソッドは、所有パーサーをフォルダーに関連付けないため、使用しないでください。

createElementAfter(int)
createElementAfter(int, String, Object) 
createElementAsFirstChild(int) 
createElementAsFirstChild(int, String, Object) 
createElementAsLastChild(int) 
createElementAsLastChild(int, String, Object) 
createElementBefore(int) 
createElementBefore(int, String, Object) 

例:

1. 出力ターミナル "out" にメッセージを伝搬するには、次のようにします。

   MbOutputTerminal out = getOutputTerminal("out");
           out.propagate(newAssembly);

2. Label ノードにメッセージを伝搬するには、次のようにします。

   MbRoute label1 = getRoute ("label1");
   Label1.propagate(newAssembly);

同じ MbMessage オブジェクトを複数回伝搬するには、MBMessage オブジェクトで finalizeMessage() メソッドを呼び出します。これにより、メッセージに対して行われたすべての変更が、Java ノードのダウンストリームで生成されるビット・ストリームに反映されます。以下に例を示します。

MbMessage newMsg = new MbMessage(assembly.getMessage());
MbMessageAssembly newAssembly = new MbMessageAssembly(assembly, newMsg);
...
newMsg.finalizeMessage(MbMessage.FINALIZE_NONE);
out.propagate(newAssembly;
...
newMsg.finalizeMessage(MbMessage.FINALIZE_NONE);
out.propagate(newAssembly);

public static String getNodeName()
{
   return "BasicNode";
}

このメソッドが宣言されていない場合、Java API フレームワークは以下の規則を使用してデフォルトのノード名を作成します。

• パッケージ名にはクラス名が付加されます。
• ドットは除去され、 パッケージ名とクラス名の各部の最初の文字が大文字になります。

例えば、 デフォルトでは以下のクラスにノード名 "ComIbmPluginsamplesBasicNode" が割り当てられます。

package com.ibm.pluginsamples;
public class BasicNode extends MbNode implements MbNodeInterface
{
   ...

evaluate メソッドには、統合ノードによって渡される以下の 2 つのパラメーターがあります。

1. MbMessageAssembly。 これには、適切なメソッドを使用してアクセスできる以下のオブジェクトが含まれています。
   • 着信メッセージ
   • LocalEnvironment
   • グローバルな Environment
   • ExceptionList
2. メッセージが着信した入力ターミナル。

例えば、次のコードの抜粋は、evaluate メソッドをどのように書き表せばよいかを示しています。

public void evaluate(MbMessageAssembly assembly, MbInputTerminal inTerm) throws MbException
  {
    // add message processing code here

    getOutputTerminal("out").propagate(assembly);
  }

ノードのインスタンスは、次のいずれかの場合に削除します。

• 統合ノードがシャットダウンされた。
• ノードまたはノードを含むメッセージ・フローを除去し、 構成を再デプロイした。

ノードが、例えばソケットの終了などの、クリーンアップ・オペレーションを実行するようにしたい場合は、onDelete メソッドのインプリメンテーションを組み込みます。

public void onDelete()
{
  // perform node cleanup if necessary
}