Ampliación de la capacidad de un nodo de salida o proceso de mensajes Java

Los nodos pueden invocar expresiones ESQL utilizando la sintaxis ESQL de nodo de Cálculo . Puede crear y modificar los componentes del mensaje utilizando expresiones ESQL y puede hacer referencia a los elementos del mensaje de entrada y de los datos de una base de datos externa.

Puede interactuar con bases de datos desde el código Java del nodo de proceso de mensajes. El soporte que se proporciona es idéntico al soporte para el código Java que escribe para el nodo JavaCompute ; para obtener detalles de las opciones disponibles y las ventajas y restricciones que se aplican, consulte Interacción con bases de datos utilizando el nodo JavaCompute.

Utilice la clase MbException para detectar excepciones y acceder a ellas. La clase MbException devuelve una matriz de objetos de excepción que representan los hijos de una excepción en la lista de excepciones de nodo de integración. Cada elemento devuelto especifica su tipo de excepción. Si una excepción no tiene hijos, se devuelve una matriz vacía. El siguiente código de ejemplo muestra un ejemplo de cómo podría utilizar la clase MbException en el método evaluate del nodo definido por el usuario

public void evaluate(MbMessageAssembly assembly, MbInputTerminal inTerm) throws MbException
  {
    try
      {

        // plug-in functionality

      }
    catch(MbException ex)
      {
        traverse(ex, 0);

        throw ex; // if re-throwing, it must be the original exception that was caught
      }
  }

  void traverse(MbException ex, int level)
  {
    if(ex != null)
      {
        // Do whatever action here
        System.out.println("Level: " + level);
        System.out.println(ex.toString());
        System.out.println("traceText:  " + ex.getTraceText());

        // traverse the hierarchy
        MbException e[] = ex.getNestedExceptions();
        int size = e.length;
        for(int i = 0; i < size; i++)
          {
            traverse(e[i], level + 1);
          }
      }
  }

Puede desarrollar un proceso de mensaje definido por el usuario o un nodo de salida de tal forma que éste pueda acceder a todas las excepciones actuales. Por ejemplo, para detectar excepciones, puede utilizar la clase MbSQLStatement. Esta clase establece el valor del atributo 'throwExceptionOnDatabaseError', que determina el comportamiento de nodo de integración cuando encuentra un error de base de datos. Si se establece en verdadero, cuando se genera una excepción, el método evaluate puede detectarla y manejarla en la extensión definida por el usuario.

El siguiente código de ejemplo muestra un ejemplo de cómo utilizar la clase MbSQLStatement.

public void evaluate(MbMessageAssembly assembly, MbInputTerminal inTerm) throws MbException
  {
    MbMessage newMsg = new MbMessage(assembly.getMessage());
    MbMessageAssembly newAssembly = new MbMessageAssembly(assembly, newMsg);

    String table = 
       assembly.getMessage().getRootElement().getLastChild().getFirstChild().getName();

    MbSQLStatement state = createSQLStatement( "dbName", 
       "SET OutputRoot.XMLNS.integer[] = PASSTHRU('SELECT * FROM " + table + "');" );

    state.setThrowExceptionOnDatabaseError(false);
    state.setTreatWarningsAsErrors(true);

    state.select( assembly, newAssembly );

    int sqlCode = state.getSQLCode();
    if(sqlCode != 0)
      {
        // Do error handling here

        System.out.println("sqlCode = " + sqlCode);
        System.out.println("sqlNativeError = " + state.getSQLNativeError());
        System.out.println("sqlState = " + state.getSQLState());
        System.out.println("sqlErrorText = " + state.getSQLErrorText());
      }

    getOutputTerminal("out").propagate(newAssembly);
  }

Para grabar en un dispositivo de salida, es necesario volver a convertir el mensaje lógico (jerárquico) a una corriente de bits en su método evaluate. Utilice el método getBuffer en MbMessage para realizar esta tarea:

public void evaluate( MbMessageAssembly assembly, MbInputTerminal in)
                                                     throws MbException
{
  MbMessage msg = assembly.getMessage();
  byte[] bitstream = msg.getBuffer();

  // write the bitstream out somewhere
  writeBitstream( bitstream );   // user method

 }

Normalmente, dado que para un nodo de salida el mensaje no se propaga a ningún terminal de salida, simplemente puede volver a este punto.

Debe utilizar el nodo MQOutput proporcionado al grabar en colas WebSphere® MQ , porque el nodo de integración mantiene internamente una conexión WebSphere MQ y los manejadores de colas abiertos en una base de hebra por hebra. Estos manejadores se colocan en la memoria caché para optimizar el rendimiento. Además, el nodo de integración maneja casos de excepción cuando se producen determinados sucesos de WebSphere MQ , y esta recuperación se ve afectada negativamente si se utilizan llamadas de WebSphere MQ MQI en un nodo de salida definido por el usuario.