Este ejemplo muestra que sólo se permite a un nodo MQInput a la vez tomar mensajes de una cola compartida cuando flujos de mensajes que se ejecutan en grupos de ejecución independientes del mismo intermediario utilizan la misma señal de serialización.
Se despliega un flujo de mensajes idéntico MyFlowA en dos grupos de ejecución denominados MYGroupA y MYGroupB en el intermediario MQ01BRK.
En este caso, no es requisito que el gestor de colas participe en un grupo de compartimiento de colas. La cola de entrada INQueue se define como local con la disposición QMGR.
BIP2656I MQ01BRK MyGroupB 11 NO SE HA PODIDO ABRIR LA COLA 'INQueue' EN EL GESTOR DE COLAS DE WEBSPHERE BUSINESS INTEGRATION 'MQ01': PORQUE LA SEÑAL DE SERIALIZACIÓN MyToken123ABC ya se está utilizando. NO SE REQUIERE NINGUNA ACCIÓN DEL USUARIO
El flujo de mensajes MyFlowA del grupo de ejecución MyGroupB no puede procesar entrada porque el señal de serialización que ha pasado ya está siendo utilizando en el gestor de colas (por el nodo MQInput del flujo de mensajes MyFlowA del grupo de ejecución MyGroupA). Esto se indica mediante el código de razón 2271 (MQRC_CONN_TAG_IN_USE) en el mensaje bip2623.
Si el operador cancela el primer grupo de ejecución o si dicho grupo termina anormalmente o se suprime durante un redespliegue de la configuración de intermediario, ahora el nodo de entrada del segundo grupo de ejecución puede obtener los mensajes de entrada de la cola INQueue.
BIP2091I MQ01BRK MyGroupB 11 EL INTERMEDIARIO SE HA VUELTO A CONECTAR A WEBSPHERE BUSINESS INTEGRATION CORRECTAMENTE: ImbCommonInputNode(785)
Ahora el flujo de mensajes MyFlowA del grupo de ejecución MyGroupB puede recuperar el proceso de los mensajes de la cola compartida INQueue.QSG.
Tenga en cuenta que, aunque se puede lograr la serialización de la entrada de un modo similar configurando la cola de entrada para entrada exclusiva, esto no asegura la integridad de los mensajes durante una situación de recuperación. Esto sólo se puede lograr utilizando la señal de serialización como se describe en este ejemplo.