Si está utilizando WebSphere MQ como el protocolo de transporte para los flujos de agregación, puede correlacionar el mensaje de petición inicial con el mensaje de respuesta combinado conservando el MsgId del MQMD de entrada y utilizándolo como el CorrelId de la respuesta de salida.
Antes de comenzar:
Para realizar esta tarea, debe haber completado las tareas siguientes:
Cuando el flujo ramificado procesa la petición inicial, se pierde el MsgId que se conserva en MQMD. Si desea correlacionar el mensaje de salida agregado con el mensaje de entrada original, un modo de hacerlo es conservar el MsgId y especificarlo como el CorrelId en el mensaje de salida agregado.
En la tarea descrita se presupone que ya ha creado un flujo ramificado y un flujo de abanico de entrada como dos flujos distintos que se ejecutan en el mismo intermediario. También presupone el contenido mínimo para estos flujos. Los flujos pueden incluir el contenido que resulte adecuado y puede adaptarlos del modo que se muestra aquí para añadir esta función adicional.
CREATE COMPUTE MODULE SaveMsgId CREATE FUNCTION Main() RETURNS BOOLEAN BEGIN CALL CopyMessageHeaders(); // Extraer y conservar el MsgId del mensaje de petición original SET OutputRoot.XML.MyMsgId = InputRoot.MQMD.MsgId; END; CREATE PROCEDURE CopyMessageHeaders() BEGIN DECLARE I INTEGER 1; DECLARE J INTEGER CARDINALITY(InputRoot.*[]); WHILE I < J DO SET OutputRoot.*[I] = InputRoot.*[I]; SET I = I + 1; END WHILE; END; END MODULE;
SET OutputRoot.MQMD.Version = MQMD_CURRENT_VERSION; // Almacenar el valor MsgId de MQMD de la carpeta especificada en el campo MQMD CorrelId SET OutputRoot.MQMD.CorrelId = CAST(InputRoot.ComIbmAggregateReplyBody.SavedMSGID.XML.MyMsgId AS BLOB);A continuación, se muestra el flujo ramificado. El SetCorrelID del nodo Compute procesa las respuestas para crear un mensaje de respuesta combinado y ahora establece el identificador de correlación MQMD para asociar esta respuesta con la petición inicial:
Conceptos relacionados
Flujos de mensajes
Agregación de flujos de mensajes
Tareas relacionadas
Configuración de flujos de agregación
Diseño de un flujo de mensajes
Creación de un flujo de mensajes
Definición del contenido del flujo de mensajes
Referencia relacionada
Nodo AggregateControl
Nodo AggregateReply
Nodo AggregateRequest
Avisos |
Marcas registradas |
Descargas |
Biblioteca |
Soporte |
Información de retorno (feedback)
![]() ![]() |
ac20410_ |