El flujo de abanico de entrada de agregaciones recibe las respuestas a los mesajes de solicitud que ha enviado el flujo ramificado y crea un mensaje de respuesta combinado que contiene todas las respuestas recibidas.
Antes de empezar:
Para llevar a cabo esta tarea debe haber completado la siguiente:
En función de los valores de tiempo de espera que se han especificado, el mensaje de respuesta combinado puede generarse antes de que el flujo de abanico de entrada reciba todas las respuestas.
Para revisar un ejemplo de un flujo de abanico de entrada, consulte el ejemplo Línea aérea que se proporciona con WebSphere Business Integration Message Broker.
Para crear el flujo de abanico de entrada:
Éste debe ser un nodo de entrada que dé soporte al modelo de petición/respuesta. Puede utilizar los nodos incorporados MQeInput y MQInput, o un nodo de entrada definido por el usuario que dé soporte a la petición/respuesta, o a una mezcla de estos nodos (en función de los requisitos de las aplicaciones que envían estas respuestas). La respuesta recibida por cada nodo de entrada debe enviarse por el mismo protocolo que la petición a la que corresponde (por ejemplo, si incluye un nodo MQOutput en un flujo ramificado, la respuesta a dicha petición la debe recibir un nodo MQInput en este flujo).
Esto representa la configuración más simple; si procede, puede incluir otros nodos entre el nodo de entrada y el nodo AggregateReply. Por ejemplo, es posible que desee almacenar las respuestas para fines de auditoría (en un nodo Warehouse).
Cuando se han recopilado todas las respuestas para un determinado grupo de peticiones de agregación, el nodo AggregateReply crea un mensaje de respuesta agregado y lo propaga por el terminal de salida.
El nodo AggregateReply también recibe en su terminal de control el mensaje de control que ha enviado el correspondiente nodo AggregateControl en el flujo ramificado (directa o indirectamente, como se describe en Asociación de flujos de agregaciones ramificados y de abanicos de entrada). No modifique el contenido de este mensaje de control.
La estructura del mensaje de respuesta agregado que se propaga a través del terminal de salida y la información de cómo se puede acceder a su contenido se proporciona en Acceso al contenido de mensaje combinado.
El nodo AggregateReply crea una carpeta en el árbol de mensajes combinado debajo del directorio raíz, denominado ComIbmAggregateReplyBody. Debajo de éste, crea varias carpetas con los nombres de carpetas que ha establecido en los nodos AggregateRequest. Los mensajes de respuesta asociados se transfieren debajo.
Por ejemplo, los mensajes de solicitud tienen nombres de carpeta:
El mensaje de respuesta agregado resultante creado por el nodo AggregateReply puede tener una estructura parecida a la que se muestra a continuación:
Puede utilizar un nodo Compute para acceder a la respuesta de la empresa taxi mediante el siguiente nombre de correlación:
InputRoot.ComIbmAggregateReplyBody.TAXI.xyz
El nombre de carpeta no tiene que ser exclusivo. Si tiene varias peticiones con el nombre de carpeta TAXI, puede acceder a respuestas separada utilizando la notación de subíndice de matriz, por ejemplo:
InputRoot.ComIbmAggregateReplyBody.TAXI[1].xyz InputRoot.ComIbmAggregateReplyBody.TAXI[2].xyz
Conceptos relacionados
Flujos de mensajes
Agregación de flujos de mensajes
Nodos de entrada definidos por el usuario
Nodos de salida definidos por el usuario
Tareas relacionadas
Configuración de flujos de agregación
Creación del flujo ramificado de agregaciones
Asociación de flujos de agregaciones ramificados y de abanicos de entrada
Configuración de tiempos de espera para la agregación
Utilización de varios nodos AggregateControl
Manejo de excepciones y puntos muertos de base de datos en flujos de agregaciones
Diseño de un flujo de mensajes
Creación de un flujo de mensajes
Definición del contenido del flujo de mensajes
Desarrollo de extensiones definidas por el usuario
Referencia relacionada
Nodo AggregateControl
Nodo AggregateReply
Nodo AggregateRequest
Nodo Compute
Nodo MQeInput
Nodo MQeOutput
Nodo MQInput
Nodo MQOutput
Avisos |
Marcas registradas |
Descargas |
Biblioteca |
Soporte |
Información de retorno (feedback)
![]() ![]() |
ac12300_ |