Los pasos que se indican en este tema presuponen que está
uniendo:
- Un intermediario de WebSphere Message Broker llamado
WBRK_BROKER.
Cuando se creó dicho intermediario, se especificó el mismo nombre para el gestor de colas.
- Una red de intermediarios de WebSphere MQ Publicación/Suscripción
con un intermediario raíz MQPS_ROOT_BROKER, y dos intermediarios finales,
MQPS_BROKER1 y MQPS_BROKER2.
Sustituya estos nombres de ejemplo por los nombres de sus
intermediarios siempre que se utilicen.
Todos los mandatos que
aparecen en esta tarea deben emitirse en el sistema en el que esté
definido el recurso en cuestión. Los mandatos de
WebSphere MQ (por ejemplo, el mandato para
definir una cola) se muestran en formato MQSC. Para obtener más
información sobre mandatos de WebSphere MQ,
consulte la documentación de WebSphere MQ.
Los
siguientes pasos indican qué debe hacerse para añadir, como nodo padre
dentro de la red de intermediarios de
WebSphere MQ Publicación/Suscripción, un intermediario de
WebSphere Message Broker que ya haya creado.
Esto se muestra en el diagrama siguiente. El
intermediario de
WebSphere Message Broker
SAMPLE_BROKER se une a la red de
WebSphere MQ Publicación/Suscripción como el nuevo nodo padre (es
decir, como el padre del nodo padre original
MQPS_ROOT_BROKER).
- Asegúrese de que el grupo de ejecución por omisión del
intermediario de WebSphere Message Broker se despliega
correctamente. Este grupo de ejecución se despliega la primera
vez que se despliega un intermediario de
WebSphere Message Broker que acabe de crearse.
Puede comprobar el estado del grupo de ejecución y del intermediario desde la vista de topología en el
entorno de trabajo.
- Defina la cola que se requiere para soportar las comunicaciones
entre intermediarios con intermediarios contiguos de
WebSphere MQ Publicación/Suscripción en el gestor de colas del
intermediario de WebSphere Message Broker.
define qlocal(SYSTEM.BROKER.INTER.BROKER.COMMUNICATIONS) noshare
- Detenga el intermediario de WebSphere Message Broker:
mqsistop SAMPLE_BROKER
- Reinicie el intermediario de WebSphere Message Broker:
mqsistart SAMPLE_BROKER
Cuando se reinicie el intermediario de
WebSphere Message Broker, estará habilitado para
recibir y procesar mensajes en la cola entre intermediarios.
- Cree los recursos necesarios en el intermediario de
WebSphere Message Broker para dar soporte a la corriente
de datos de WebSphere MQ Publicación/Suscripción por omisión:
- Cree la cola de la corriente de datos por omisión:
define qlocal(SYSTEM.BROKER.DEFAULT.STREAM) noshare
- Cree un flujo de mensajes para la
publicación/suscripción. Puede ser uno propio o uno
basado en el flujo de mensajes de
publicación/suscripción suministrado:
- Inicie el entorno de trabajo y seleccione la vista del diseñador.
- Haga una copia del flujo de mensajes suministrado y déle un nuevo nombre; ha de importar
este flujo de mensajes por omisión para poder acceder a él y utilizarlo.
- Compruebe las propiedades de los nodos en el flujo de mensajes.
Ha de establecer la propiedad de la cola de entrada (corriente de datos) adecuada para el nodo MQInput. Compruebe si las demás propiedades de los nodos se han establecido correctamente para sus necesidades.
- Finalmente, despliegue el flujo de mensajes para el grupo de ejecución por omisión del
intermediario SAMPLE_BROKER.
Encontrará información más detallada para llevar a cabo estos pasos en la ayuda en línea para el
entorno de trabajo.
- Si está utilizando más corrientes de datos en la red de
WebSphere MQ Publicación/Suscripción, debe habilitarlas también en el
intermediario de WebSphere Message Broker. Aunque el intermediario de
WebSphere Message Broker puede soportar todas las
corrientes de datos de sus intermediarios de
WebSphere MQ Publicación/Suscripción contiguos, sólo necesitará
definir colas y definir y desplegar
flujos de mensajes para las corrientes de datos
requeridas por los clientes del suscriptor de
WebSphere Message Broker.
- Cree una cola local en el gestor de colas del intermediario
de WebSphere Message Broker para cada corriente de datos
en la que vayan a procesarse mensajes. Por ejemplo:
define qlocal(STREAM.X) noshare
- Cree y despliegue un
flujo de mensajes para leer y procesar los
mensajes de WebSphere MQ Publicación/Suscripción que se envían a cada
cola de corriente de datos (publicación).
Puede utilizar el flujo de mensajes de
publicación/suscripción suministrado como base para cada nuevo
flujo de mensajes. Cada nodo MQInput que represente una corriente de datos que no sea la
corriente de datos por omisión ha de tener establecida la propiedad implicitStreamNaming.
- Entre el siguiente mandato de WebSphere MQ Publicación/Suscripción para el intermediario que
sea actualmente el intermediario padre de WebSphere MQ Publicación/Suscripción a fin finalizar su actividad.
endmqbrk -c -m MQPS_ROOT_BROKER
Se solicita una conclusión controlada (-c).
Cuando haya finalizado el cierre, el intermediario se podrá reiniciar el intermediario. Puede solicitar una
conclusión inmediata especificando -i en vez de
-c, si necesita forzar la finalización de la conclusión.
- Asegúrese de que la conexión de WebSphere MQ entre los dos intermediarios esté activa;
debe iniciar los escuchas para los canales receptores y, a continuación, iniciar los canales emisores.
- Entre el siguiente mandato de WebSphere MQ Publicación/Suscripción para el intermediario que
sea actualmente el intermediario padre de WebSphere MQ Publicación/Suscripción a fin de reiniciarlo:
strmqbrk -m MQPS_ROOT_BROKER -p SAMPLE_BROKER
Si
el gestor de colas asociado al intermediario de
WebSphere Message Broker SAMPLE_BROKER no se ha creado
con el mismo nombre que el intermediario, deberá especificar aquí el
nombre del gestor de colas después del indicador -p y no
el nombre del intermediario.
- Compruebe si la integración se ha realizado correctamente:
mqsilistmqpubsub SAMPLE_BROKER
Si el intermediario
de
WebSphere Message Broker se ha integrado en la red de
WebSphere MQ Publicación/Suscripción correctamente, verá una
respuesta parecida a la siguiente:
BIP8090I: El
intermediario contiguo de WebSphere MQ Publicación/Suscripción SAMPLE_BROKER
está activo
BIP8091I: Corriente de datos común SYSTEM.BROKER.DEFAULT.STREAM
BIP8091I: Corriente de datos común STREAM.X