WebSphere Message Broker, Versión 8.0.0.5 Sistemas operativos: AIX, HP-Itanium, Linux, Solaris, Windows, z/OS

Consulte la información sobre la última versión del producto en IBM Integration Bus, Versión 9.0

Crear un flujo que utilice colecciones de mensajes

Utilice un nodo Collector en el flujo de mensajes para agrupar mensajes de uno o más orígenes en una colección de mensajes. Puede añadir terminales de entrada dinámicos al nodo Collector para cada origen de mensaje que desee configurar para el flujo de mensajes.

Antes de empezar:

Realice las siguientes tareas.

También puede utilizar un nodo Compute para crear una colección de mensajes utilizando ESQL, que es útil si los mensajes deben agruparse para el análisis, o si la colección de mensajes debe construirse para representar una estructura de datos en particular, como por ejemplo una estructura de datos de canal de CICS Transaction Server for z/OS. Para obtener más información sobre la utilización de ESQL para crear una colección de mensajes, consulte Crear una colección de mensajes utilizando ESQL.

Examine el ejemplo siguiente para saber cómo utilizar el nodo Collector para la colección de mensajes:

Puede ver información sobre los ejemplos sólo cuando utilice el Information Center que está integrado en WebSphere Message Broker Toolkit o el Information Center en línea. Puede ejecutar ejemplos sólo cuando utilice el Information Center que está integrado en WebSphere Message Broker Toolkit.

Para crear un flujo de mensajes para generar y procesar colecciones de mensajes:

  1. Cree un nuevo flujo de mensajes.
  2. Añada los nodos de entrada en la vista del editor. Los nodos de entrada reciben los mensajes desde los que se generan las colecciones de mensajes. Puede utilizar cualquiera de los nodos incorporados o los nodos de entrada definidos por el usuario. Configúrelos y conéctelos tal como se describe.
    1. Añada un nodo de entrada para cada origen de mensajes de entrada del flujo de mensajes, por ejemplo, un nodo MQInput y un nodo JMSInput.
    2. Seleccione cada uno de los nodos de entrada para mostrar sus propiedades en la vista Propiedades.
    3. Especifique el origen de los mensajes de entrada para cada nodo. Por ejemplo, especifique el nombre de una cola de WebSphere en la propiedad básica Nombre de cola de la que el nodo MQInput recupera los mensajes.
    4. Opcional: especifique valores para cualquier otra propiedad que desee configurar para cada nodo.
  3. Añada el nodo Collector en la vista del editor. El nodo Collector recibe mensajes de nodos de entrada u otros nodos del flujo de mensajes. Debe añadir un terminal de entrada dinámico al nodo Collector para cada origen del mensaje de entrada para poder conectar los nodos de entrada o cualquiera de los nodos en sentido ascendente con el nodo Collector. Configúrelos y conéctelos tal como se describe.
    1. Añada un nodo Collector al flujo de mensajes.
    2. Pulse el botón derecho del nodo Collector y pulse Añadir terminal de entrada para añadir un terminal de entrada dinámico nuevo al nodo Collector. Añada un nuevo terminal de entrada para cada origen de entrada que tenga previsto añadir al flujo de mensajes; para más información sobre cómo añadir un terminal de entrada dinámico, consulte Adición de un terminal de entrada a un nodo Collector para cada origen de entrada.
    3. Conecte el terminal de salida de cada nodo de entrada con un terminal de entrada dinámico distinto del nodo Collector. Esto representa la configuración más sencilla; si procede, puede incluir otros nodos entre el nodo de entrada y el nodo Collector. Por ejemplo, si desea almacenar la petición con para realizar una auditoría (en un nodo Database) o añadir un identificador exclusivo al mensaje (en un nodo Compute).
  4. Añada nodos de proceso al flujo de mensajes. Puede procesar colecciones de mensajes de un nodo Collector utilizando sólo los siguientes nodos:
    • Compute
    • JavaCompute

    Debe conectar un nodo Compute o un nodo JavaCompute con el nodo Collector del flujo de mensajes. Utilice estos nodos para procesar la colección de mensajes y propagar otros mensajes. Puede utilizar ESQL o XPATH para acceder al contenido de los mensajes individuales de la colección de mensajes para su proceso. Para procesar una colección de mensajes:

    1. Añada un nodo Compute o un nodo JavaCompute al flujo de mensajes.
    2. Utilice código ESQL o Java™ para crear mensajes de salida individuales a partir de una colección de mensajes.
    3. Opcional: especifique valores para las demás propiedades que desee configurar para este nodo de proceso.
    4. Conecte el terminal de salida del nodo de proceso con el terminal de entrada de un nodo de salida u otro nodo de proceso.
    5. Opcional: añada otros nodos al flujo de mensajes para su proceso adicional.
  5. Incluya uno o varios nodos de salida para el flujo de mensajes. Estos nodos pueden ser cualquiera de los nodos incorporados, o un nodo de salida definido por el usuario. Un nodo de salida no puede procesar una colección de mensajes, por lo que deberá asegurarse de conectar el nodo de salida con un nodo de proceso que propague mensajes de salida individuales. Para configurar un nodo de salida:
    1. Seleccione cada uno de los nodos de salida para mostrar sus propiedades en la vista Propiedades.
    2. Especifique las propiedades de destino de cada nodo. Por ejemplo, especifique el nombre de una cola de WebSphere MQ en la propiedad básica Nombre de cola a la que el nodo MQOutput envía los mensajes.
    3. Opcional: especifique valores para cualquier otra propiedad que desee configurar para cada nodo.
  6. Incluya proceso para errores de manejo y colecciones de mensajes caducadas:
    1. Opcional: añada nodos de proceso al flujo de mensajes para manejar colecciones de mensajes caducadas. Conecte estos nodos al terminal de caducidad (Expire) del nodo Collector.
    2. Opcional: añada nodos de proceso o de manejo de errores para gestionar todas las excepciones del flujo de mensajes. Conecte estos nodos al terminal de captación (Catch) del nodo Collector
    Si se ha detectado un error en sentido descendente de un nodo Collector, el intermediario genera una excepción. La colección de mensajes se propaga al terminal Catch del nodo Collector. Conecte el terminal Catch (de captación) con una secuencia de nodos que maneje los errores para evitar la pérdida de datos y asegúrese de que no se puedan generar más excepciones durante el proceso de errores. El nodo conectado al terminal Catch (de captación) debe ser un nodo Compute o un nodo JavaCompute para gestionar la colección de mensajes.
  7. Pulse Control-S o Archivo > Guardar nombre en el menú de la barra de tareas (donde nombre es el nombre de este flujo de mensajes) para guardar el flujo de mensajes y validar su configuración.
Si desea controlar cuando se propagan las colecciones de mensajes completas, también debe añadir nodos adicionales al flujo de mensajes. Para obtener más información, consulte Utilización de mensajes de control con el nodo Collector.
A continuación: Configure el nodo Collector.
Avisos | Marcas registradas | Descargas | Biblioteca | Soporte | Comentarios

Copyright IBM Corporation 1999, 2014Copyright IBM Corporation 1999, 2014.

        
        Última actualización:
        
        Última actualización: 2015-02-28 16:58:42


Tema de tareaTema de tarea | Versión 8.0.0.5 | ac37700_