Utilice los siguientes enlaces para obtener más información sobre cómo utilizar la supervisión de flujos de mensajes:
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.
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.
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.
La Carga útil del suceso especifica que los datos empresariales PartNumber están supervisados.
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.
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.
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.
En WebSphere MQ Explorer, cree una suscripción al tema creado anteriormente, especificando el destino:
WSAGGREGATIONSAMPLE.MONITOR
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:
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: