El flujo de mensajes de abanico de entrada de agregación recibe las respuestas a los mensajes de petición enviados por el flujo de mensajes de abanico de salida y crea un mensaje de respuesta combinado que contiene todas las respuestas recibidas.
Antes de comenzar:
Para realizar esta tarea, debe haber realizado las tareas siguientes:
Antes de realizar esta tarea, se recomienda también leer la visión general sobre la Agregación de flujo de mensajes.En función de que el flujo de abanico de salida sea transaccional y, si no lo es, de los valores de tiempo de espera que ha especificado, es posible que el mensaje de respuesta combinado se genere antes de que que el flujo de abanico de entrada reciba todas las respuestas. Consulte Creación del flujo de mensajes de abanico de salida de agregación para obtener más información sobre este tema.
Para revisar un ejemplo de un flujo de mensajes de abanico de entrada, consulte el ejemplo Reserva de vuelos en Línea aérea que se proporciona con WebSphere Message Broker.
Para crear el flujo de mensajes de abanico de entrada:
El nodo AggregateReply crea una carpeta en el árbol de mensaje combinados debajo de Raíz, denominada ComIbmAggregateReplyBody. Debajo de esta, crea diferentes carpetas que utilizan los nombres de carpeta que ha establecido en los nodos AggregateRequest. Los mensajes de respuesta asociados se colocan debajo de las mismas.
Por ejemplo, los mensajes de petición pueden tener los siguientes nombres de carpeta:
El mensaje de respuesta agregado resultante creado por el nodo AggregateReply puede tener una estructura similar a la que se muestra a continuación:
Puede utilizar un nodo Compute para acceder a la respuesta de la empresa de taxis utilizando el nombre de correlación siguiente:
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 las diferentes respuestas utilizando una anotación de subíndice de matriz, por ejemplo:
InputRoot.ComIbmAggregateReplyBody.TAXI[1].xyz InputRoot.ComIbmAggregateReplyBody.TAXI[2].xyz