Use os seguintes links para descobrir sobre como usar o monitoramento de fluxo de mensagens:
Na amostra Web Service Aggregation, as áreas de cobertura de parte de dados de negócios são monitoradas. A prova requer que a parte de dados seja passada pelos fluxos de mensagens. Os dados <PartNumber> na seguinte mensagem de entrada é controlada; nesse caso, o valor é ABC1234.
Essa parte de dados é usada para controlar o progresso em cada fluxo de mensagens que é monitorado em todos os nós de entrada e de saída.
Para unir eventos de monitoramento para essa parte de dados de negócios, os dados são usados como um ID da transação pai na configuração de monitoramento.
A amostra usa cinco fluxos de mensagens e é iniciada colocando a mensagem XML SOAP anterior no nó SOAPInput do fluxo de mensagens WSAggregationFanOut.msgflow.
A Carga Útil do Evento especifica que os dados de negócios PartNumber são monitorados.
O Correlacionador de transação pai especifica o campo PartNumber a partir da mensagem de entrada. Ao especificar a referência de campo aqui, e em cada outro nó que é monitorado, é possível procurar por eventos relevantes para obter informações que são relevantes ao ABC1234.
O valor ABC1234 está em cada mensagem de negócios na amostra Web Service Aggregation, mas o nome do campo pode nem sempre ser a expressão XPATH $Root/SOAP/Body/ns:OrderMessage/localElement/PartNumber. Você deve assegurar-se de que o valor XPATH correto seja especificado para cada nó.
Cada um dos nós MQOutput nesse fluxo de mensagens e todos os nós de entrada e de saída nos outros quatro fluxos de mensagens são configurados da mesma forma.
Para ativar o monitoramento no seu broker para fluxos de mensagens nessa amostra, insira um dos seguintes comandos:
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
em que myBROKER é o seu nome do broker e MyEG é o nome do seu grupo de execução.
Esses comandos ativam o monitoramento de todos os fluxos de mensagens, exceto para aquele que processa eventos de monitor (WSAggregationReadMonitordata.msgflow).
Nota: Não ative o monitoramento do grupo de execução inteiro e não ative o monitoramento explicitamente para o fluxo de mensagens WSAggregationReadMonitordata.msgflow. Fazer isso resulta em um loop de fluxo contínuo, pois o nó Input emite um evento de monitoramento para cada mensagem que ele processa. Esse evento é então lido pelo mesmo fluxo de mensagens, gerando outro evento.
Para desativar o monitoramento, insira o seguinte comando:
mqsichangeflowmonitoring myBROKER -c inactive -e MyEG -j
em que myBROKER é o seu nome do broker e MyEG é o nome do seu grupo de execução.
No Explorer do WebSphere MQ, crie um tópico com a sequência de tópicos.
$SYS/Broker/myBROKER/Monitoring/MyEG/#
em que myBROKER é o seu nome do broker e MyEG é o nome do seu grupo de execução.
No Explorer do WebSphere MQ, crie uma assinatura para o tópico criado anteriormente, especificando o destino final.
WSAGGREGATIONSAMPLE.MONITOR
Uma mensagem de publicação de exemplo é mostrada no diagrama a seguir. O nome do broker nesse caso é BROKERV70L e o nome do grupo de execução é default:
O fluxo de mensagens WSAggregationReadMonitordata.msgflow processa os dados de monitoramento a partir da fila WSAGGREGATIONSAMPLE.MONITOR. A fila é lida usando um nó MQInput. Um recebimento de dados do nó Collector do nó MQInput especifica os dados de negócios (ID da transação pai) como o identificador de correlação.
No nó Collector, o caminho de correlação é configurado para $Root/XMLNSC//@*[local-name()='parentTransactionId'] para que todas as mensagens de evento de monitor para o qual o atributo parentTransactionId possui um valor comum sejam capturadas em uma única coleta.
Quando todos os eventos de uma parte de dados de negócios tiverem sido lidos, uma mensagem de resumo será gravada no arquivo businessdata.xml. Um exemplo de arquivo de saída ABC1234.xml é mostrado no diagrama a seguir: