Vorbereitungen:
Zur Beendigung dieser Task müssen Sie Ihrem Nachrichtenfluss einen Java-Rechenknoten hinzufügen.
public class jcn2 extends MbJavaComputeNode { public void evaluate(MbMessageAssembly assembly) throws MbException { MbOutputTerminal out = getOutputTerminal("out"); MbOutputTerminal alt = getOutputTerminal("alternate"); MbMessage message = assembly.getMessage(); // ---------------------------------------------------------- // Benutzercode unten hinzufügen // Ende von Benutzercode // ---------------------------------------------------------- // Die folgenden Angaben sollten nur geändert werden, // wenn Nachricht nicht an das Ausgabeterminal weitergegeben wird out.propagate(assembly); } }
Die Schablone erstellt eine Teilimplementierung einer Methode mit der Bezeichnung evaluate(). Der Broker ruft die Methode evaluate() für jede Nachricht, die durch den Knoten geleitet wird, einmal auf. Bei dem Parameter, der an evaluate() übermittelt wird, handelt es sich um Nachrichtenassembly. Die Nachrichtenassembly bindet die Nachricht ein, die vom vorhergehenden Knoten im Nachrichtenfluss weitergegeben wird.
Durch das Hinzufügen von angepasstem Code zu der Schablone und durch die Weitergabe an das Ausgangsterminal und an das alternative Terminal können Sie einen Nachrichtenfilter erstellen.