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 empezar:
Para realizar esta tarea, debe haber completado la tarea siguiente:
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 si el flujo de abanico de salida es o no 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 el flujo de abanico de entrada reciba todas las respuestas. Consulte Crear el flujo de mensajes de abanico de salida de agregación para obtener más información sobre este tema.
Es posible incluir el flujo de abanico de salida y de abanico de entrada en el mismo flujo de mensajes. Sin embargo, es aconsejable crear dos flujos independientes. No despliegue varias copias del mismo flujo de abanico de entrada en los mismos grupos de ejecución o en grupos de ejecución diferentes. Para obtener información sobre las ventajas de configurar flujos de mensajes independientes, consulte Asociar flujos de agregación de mensajes de abanico de salida y de abanico de entrada.
Para revisar un ejemplo de un flujo de abanico de entrada, consulte el ejemplo de Ejemplo Reserva de vuelos 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