Prima di iniziare
Per completare tale attività, aggiungere un Nodo JavaCompute al flusso di messaggi.
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); } }
La maschera produce un'implementazione parziale di un metodo denominato evaluate(). Il broker richiama evaluate() una volta per ciascun messaggio che viene trasmesso tramite il nodo. Il parametro trasmesso a evaluate() è l'assemblaggio del messaggio. L'assemblaggio del messaggi comprime il messaggio trasmesso al nodo precedente nel flusso di messaggi.
Aggiungere il codice personalizzato alla maschera e trasmettere i messaggi ai terminali Esterno e Alternativo per creare un filtro dei messaggi.