El flujo ramificado de agregaciones recibe el mensaje de entrada inicial y lo reorganiza de forma que muestre un número de peticiones para un número de aplicaciones de destino.
Antes de empezar:
Para llevar a cabo esta tarea debe haber completado la siguiente:
Para revisar un ejemplo de un flujo ramificado, consulte el ejemplo Línea aérea que se proporciona con WebSphere Business Integration Message Broker.
Para crear el flujo ramificado:
Esto representa la configuración más simple; si procede, puede incluir otros nodos entre el nodo de entrada y el nodo AggregateControl. Por ejemplo, es posible que desee almacenar la petición para fines de auditoría (en un nodo Warehouse), o añadir un identificador exclusivo al mensaje (en un nodo Compute).
Si las aplicaciones de destino que manejan las peticiones de subtareas pueden extraer de un solo mensaje de entrada la información que necesitan, no es necesario incluir un nodo Compute para dividir el mensaje. Puede pasar todo el mensaje de entrada a todas las aplicaciones de destino.
Si las aplicaciones de destino esperan recibir una petición individual, no todo el mensaje de entrada, debe incluir un nodo Compute para que genere cada mensaje de salida de subtarea individual a partir del mensaje de entrada. Configure cada nodo Compute de la siguiente forma, copiando el subconjunto adecuado del mensaje de entrada en cada mensaje de salida.
El nodo AggregateControl inserta elementos en el árbol de entorno local en el mensaje de entrada que el nodo AggregateRequest lee cuando llega el mensaje. Asegúrese de que entorno local se copia del mensaje de entrada al mensaje de salida en el nodo Compute. Esto ocurre de forma automática a menos que especifique un valor que incluya el entorno local (uno de los valores Todos, Entorno local, Entorno local y mensaje o Excepción y entorno local).
Si especifica uno de estos valores, el intermediario da por supuesto que está personalizando el nodo Compute con ESQL que escribe en el entorno local y que copiará todos los elementos de este árbol que son necesarios en la mensaje de salida.
Si desea modificar el entorno local, añada la siguiente sentencia para copiar la información de agregación necesaria del mensaje de entrada en el mensaje de salida:
SET OutputLocalEnvironment.ComIbmAggregateControlNode = InputLocalEnvironment.ComIbmAggregateControlNode;
Éste debe ser un nodo de salida que dé soporte al modelo de petición/respuesta. Puede utilizar los nodos incorporados MQeOutput y MQOutput, o un nodo de salida definido por el usuario que dé soporte a la petición/respuesta, o una mezcla de estos nodos (en función de los requisitos de las aplicaciones de destino).
La información escrita por los nodos incorporados es el nombre de la cola, el nombre del gestor, el ID de mensaje y el ID de correlación (de MQMD) y el identificador de respuesta de mensaje (establecido en el mismo valor que el ID de mensaje).
Si utiliza un nodo de salida definido por el usuario, asegúrese de que el nodo almacena información equivalente en WrittenDestination. Para más información, consulte Protocolos soportados para la agregación.
El nodo AggregateRequest escribe un registro en la base de datos del intermediario para cada mensaje que procesa. Esto permite al nodo AggregateReply identificar con qué petición está asociada cada respuesta. Si los nodos de salida no son transaccionales, el mensaje de respuesta puede llegar al flujo de abanico de entrada antes que se confirme esta actualización de base de datos. Consulte Configuración de tiempos de espera para la agregación para obtener detalles sobre cómo utilizar los tiempos de espera para evitar que esto ocurra.
Conceptos relacionados
Flujos de mensajes
Árbol LocalEnvironment
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 de un flujo de abanico de entrada de agregación
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
Generación de varios mensajes de salida
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)
![]() ![]() |
ac12290_ |