Antes de começar
O WebSphere Message Broker fornece a origem para dois nós de amostra definidos pelo usuário chamados SwitchNode e TransformNode. Você pode utilizar esses nós em seus estados atuais ou poderá modificá-los.
Conceitualmente, um nó de processamento de mensagem é utilizado para processar uma mensagem de alguma forma e um nó de saída é utilizado para enviar uma mensagem para a saída como um fluxo de bits. Entretanto, quando se codifica um nó de processamento de mensagem ou um nó de saída, eles são essencialmente a mesma coisa. Você pode desempenhar o processamento de mensagens em um nó de saída e, de forma semelhante, pode exibir uma mensagem para um fluxo de bits utilizando um nó do processamento de mensagens. Para simplificar, este tópico refere-se principalmente ao nó como um nó de processamento de mensagem, no entanto, ele discute a funcionalidade dos dois tipos de nó.
O painel Definições Java é exibido.
Qualquer classe que implemente a MbNodeInterface e esteja contida no classpath do intermediário (ou no caminho da LIL) é registrada com o intermediário como um nó de processamento de mensagem. Ao implementar MbNodeInterface, você também deve implementar um método evaluate para essa classe. O método evaluate é chamado pelo intermediário para cada mensagem que é transmitida através do fluxo.
package com.ibm.jplugins; import com.ibm.broker.plugin.*; public class BasicNode extends MbNode implements MbNodeInterface
Quando o nó é instanciado, o construtor da classe de nó do usuário é chamado. É aqui que são criados os terminais do nó e inicializados quaisquer valores padrão para os atributos.
Um nó de processamento de mensagem tem um número de terminais de entrada e de terminais de saída associados a ele. Os métodos createInputTerminal e createOutputTerminal são utilizados para incluir terminais em um nó quando ele é instanciado. Por exemplo, para criar um nó com um terminal de entrada e dois terminais de saída:
public MyNode() throws MbException { // criar os terminais aqui createInputTerminal ("in"); createOutputTerminal ("out"); createOutputTerminal ("failure"); }
É necessário declarar o nome do nó como ele será identificado pelo workbench. Todos os nomes de nós devem terminar com "Node". O nome é declarado utilizando o seguinte método:
public static String getNodeName() { return "BasicNode"; }
package com.ibm.pluginsamples; public class BasicNode extends MbNode implements MbNodeInterface { ...
Os atributos do nó são declarados da mesma forma que propriedades de Java Bean. Você é responsável por escrever métodos getter e setter para os atributos e a estrutura da API infere os nomes dos atributos utilizando as regras de introspecção do Java Bean. Por exemplo, se você declarar os dois métodos seguintes:
private String attributeVariable; public String getFirstAttribute() { return attributeVariable; } publc void setFirstAttribute(String value) { attributeVariable = value; }
O intermediário inferirá que esse nó tem um atributo chamado firstAttribute. Esse nome é derivado dos nomes dos métodos get ou set, não de nenhum nome de variável de membro de classe interna. Os atributos somente podem ser expostos como cadeias, portanto é preciso converter qualquer tipo numérico para e de cadeias nos métodos get ou set. Por exemplo, o método a seguir define um atributo chamado timeInSeconds:
int seconds; public String getTimeInSeconds() { return Integer.toString(seconds); } public void setTimeInSeconds(String value) { seconds = Integer.parseInt(value); }
Conforme descrito anteriormente, para nós de processamento de mensagem ou saída, você deve implementar o método evaluate definido em MbNodeInterface. Ele é chamado pelo intermediário para processar a mensagem. Esse método deve fornecer toda a função de processamento para o nó.
Os dados do fluxo de mensagens, ou seja, a mensagem, o ambiente global, o ambiente local e a lista de exceção, são recebidos no terminal de entrada do nó.
O método onDelete é implementado da seguinte maneira:
public void onDelete() { // executar limpeza do nó se necessário }