Supervisión del ejemplo de agregación de servicios web

Utilice los siguientes enlaces para obtener más información sobre cómo utilizar la supervisión de flujos de mensajes:

Decida qué desea supervisar

En el ejemplo de agregación de servicios web se supervisan los huellas de un fragmento de datos empresariales. Es necesario mostrar que el fragmento de datos ha pasado por los flujos de mensajes. Se realiza un seguimiento de los datos <PartNumber> en el siguiente mensaje de entrada; en este caso, el valor es ABC1234.

Mensaje de ejemplo

Este fragmento de datos se utiliza para realizar un seguimiento del progreso a través de cada uno de los flujos de mensaje supervisados en todos los nodos de entrada y de salida.

Para enlazar los sucesos de supervisión para este fragmento de datos empresariales, los datos se utilizan como ID de transacción padre en la configuración de supervisión.

Configure parámetros de supervisión en los flujos de mensajes

el ejemplo utiliza cinco flujos de mensajes y se inicia colocando el mensaje XML SOAP anterior en el nodo SOAPInput del flujo de mensajes WSAggregationFanOut.msgflow.

WSAggregationFanOut.msgflow

WSAggregationFanOut.msgflow

  1. Para ver los valores de supervisión, en la pestaña Propiedades del nodo SOAPInput, pulse la pestaña Supervisión. Los valores de supervisión para el nodo SOAPInput se muestran en el siguiente diagrama:

    Mon1

  2. Pulse la fila que contiene Inicio de transacción y, a continuación, pulse Editar. Se abre la ventana "Editar suceso":

    Mon2

    La Carga útil del suceso especifica que los datos empresariales PartNumber están supervisados.

  3. Para obtener más información sobre la correlación de sucesos, pulse la pestaña Correlación.

    Mon3

    El Correlacionador de transacciones padre especifica el campo PartNumber del mensaje de entrada. Al especificar aquí la referencia del campo, así como también en cualquier otro nodo que se supervise, puede buscar los sucesos resultantes para obtener información relevante para ABC1234.

    El valor ABC1234 se encuentra todos los mensajes empresariales del ejemplo de agregación de servicios web, pero es posible que el nombre del campo no sea siempre la expresión XPATH $Root/SOAP/Body/ns:OrderMessage/localElement/PartNumber. Debe asegurarse de que el valor XPATH sea correcto para cada nodo.

Cada uno de los nodos MQOutput de este flujo de mensajes, y todos los nodos de entrada y salida de los otros cuatro flujos de mensajes, están configurados de forma similar.

Habilite la supervisión en la ejecución de WebSphere Message Broker

Para habilitar la supervisión en el intermediario para los flujos de mensajes de este ejemplo, especifique los siguientes mandatos:


mqsichangeflowmonitoring myBROKER -c active -e MyEG -f WSAggregationFanOut


mqsichangeflowmonitoring myBROKER -c active -e MyEG -f WSAggregationMQtoSOAP

mqsichangeflowmonitoring myBROKER -c active -e MyEG -f WSAggregationTargetWS

mqsichangeflowmonitoring myBROKER -c active -e MyEG -f WSAggregationSOAPtoMQ

mqsichangeflowmonitoring myBROKER -c active -e MyEG -f WSAggregationFanIn

donde myBROKER es el nombre de su intermediario, y MyEG, el nombre del grupo de ejecución.

Estos mandatos habilitan la supervisión para todos los flujos de mensajes, con la excepción del que procesa sucesos de supervisión (WSAggregationReadMonitordata.msgflow).

Nota: no habilite la supervisión para todo el grupo de ejecución y no habilite la supervisión de forma explícita para el flujo de mensajes WSAggregationReadMonitordata.msgflow. Si lo hace, este flujo de mensajes entra en bucle continuo porque el nodo de entrada emite un suceso de supervisión para cada uno de los mensajes que procesa. Este suceso luego se lee en el mismo flujo de mensajes, que genera otro suceso.

Para inhabilitar la supervisión, especifique el siguiente mandato:


mqsichangeflowmonitoring myBROKER -c inactive -e MyEG -j

donde myBROKER es el nombre de su intermediario, y MyEG, el nombre del grupo de ejecución.

Cree temas de supervisión en publicación/suscripción de WebSphere MQ

En WebSphere MQ Explorer, cree un tema con la siguiente serie de tema:


 
$SYS/Broker/myBROKER/Monitoring/MyEG/#

donde myBROKER es el nombre de su intermediario, y MyEG, el nombre del grupo de ejecución.

Suscríbase al tema de supervisión

En WebSphere MQ Explorer, cree una suscripción al tema creado anteriormente, especificando el destino:

WSAGGREGATIONSAMPLE.MONITOR

Procese las publicaciones que se envían a la suscripción

En el siguiente diagrama se muestra un mensaje de publicación de ejemplo. En este caso, el nombre del intermediario es BROKERV70L y el nombre del grupo de ejecución es default:

Mon4

El flujo de mensajes WSAggregationReadMonitordata.msgflow procesa los datos de supervisión de la cola WSAGGREGATIONSAMPLE.MONITOR. La cola se lee utilizando un nodo MQInput. Un nodo Collector en sentido descendente desde el nodo MQInput especifica los datos empresariales (ID de transacción padre) como identificador de correlación.

En el nodo Collector, la vía de acceso de correlación se establece en $Root/XMLNSC//@*[local-name()='parentTransactionId'] de modo que todos los mensajes de sucesos de supervisor para los que parentTransactionId tiene un valor común se capturen en una misma colección.

Una vez que se han leído todos los sucesos de un fragmento de datos empresariales, se escribe un mensaje de resumen en el archivo businessdata.xml. En el siguiente diagrama se muestra el archivo de salida de ejemplo ABC1234.xml:

Mon5

Volver a Ejecutar el ejemplo

Volver a la página inicial del ejemplo