Este exemplo demonstra que somente um nó input por vez tira mensagens de uma fila compartilhada quando o token de serialização é utilizado pelos fluxos de mensagens em execução em intermediários separados.
Um fluxo de mensagens idêntico MyFlowA é implementado para um grupo de execução chamado MYGroupA em cada intermediário. Observe que os fluxos de mensagens não precisam ser idênticos; o ponto significativo é que um token de serialização idêntico seja utilizado para ambos fluxos.
O fluxo de mensagem simples neste exemplo consiste em um nó MQInput conectado a um nó MQOutput. O nó MQInput em ambos fluxos de mensagens obtém mensagens da fila compartilhada INQueue.QSG; o atributo Serialization Token do nó é configurado como MyToken123ABC em ambos nós MQInput.
A propriedade do fluxo de mensagens instâncias adicionais utiliza o valor padrão zero em ambos fluxos de mensagens, o que assegura que a entrada seja serializada no fluxo.
BIP2656I MQ02BRK MyGroupA 17 NÃO FOI POSSÍVEL ABRIR A FILA 'INQueue.QSG' NO WEBSPHERE BUSINESS INTEGRATION QUEUE MANAGER 'MQ02': CÓDIGO DE CONCLUSÃO 2; CÓDIGO DE RAZÃO 2271. :ImbCommonInputNode(759) POIS O TOKEN DE SERIALIZAÇÃO MyToken123ABC já está em utilização. NENHUMA AÇÃO DO USUÁRIO É REQUERIDA.
Observe que essa mensagem é reproduzida a cada 30 minutos.
O fluxo de mensagens MyFlowA do grupo de execução MyGroupA em execução no intermediário MQ02BRK não pode processar entrada, pois o token de serialização que transmitiu já está sendo utilizado no grupo de compartilhamento de filas. Isso é indicado pelo código de razão 2271 (MQRC_CONN_TAG_IN_USE) na mensagem bip2623.
BIP2091I MQ02BRK MyGroupA 17 O INTERMEDIÁRIO RECONECTOU AO WEBSPHERE BUSINESS INTEGRATION COM ÊXITO : ImbCommonInputNode(785)
BIP9142I MQ01BRK 0 O COMPONENTE PAROU. : ImbControlService(594)
A seqüência anterior de eventos também ocorre se o intermediário MQ01BRK falhar, em vez de parar através de um pedido do operador ou se uma nova configuração de intermediário for implementada para MQ01BRK que exclui ou modifica o fluxo de mensagens MyFlowA.
Essa disposição também pode ser utilizada quando o requisito for migrar o processamento de mensagens entre intermediários em execução em diferentes imagens do sistema z/OS que estão conectados ao mesmo Recurso de Acoplamento.