始める前に
このタスクを完了するには、 JavaCompute ノードをメッセージ・フローに追加している必要があります。
public class jcn2 extends MbJavaComputeNode { public void evaluate(MbMessageAssembly assembly) throws MbException { MbOutputTerminal out = getOutputTerminal("out"); MbOutputTerminal alt = getOutputTerminal("alternate"); MbMessage message = assembly.getMessage(); // ---------------------------------------------------------- // Add user code below // End of user code // ---------------------------------------------------------- // The following should only be changed // if not propagating message to the 'out' terminal out.propagate(assembly); } }
テンプレートは、evaluate() と呼ばれるメソッドの部分的なインプリメンテーションを生成します。 ブローカーは evaluate() をノードを通過するメッセージごとに 1 回呼び出します。 evaluate() に渡されるパラメーターは、メッセージ・アセンブリーです。 メッセージ・アセンブリーは、メッセージ・フローの直前のノードから渡された メッセージをカプセル化します。
カスタム・コードをテンプレートに追加し、Out および Alternate の両方のターミナルにメッセージを伝搬して、 メッセージ・フィルターを作成します。