开始之前
要完成该任务,必须已将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()。传递给 evaluate() 的参数是消息套件。该消息套件封装从消息流中的前一个节点传递来的消息。
将定制的代码添加到模板,并将消息传播到 Out 和 Alternate 终端以创建消息过滤器。