O fluxo de recepção de agregação recebe as respostas para as mensagens de pedido enviadas pelo fluxo de difusão e constrói uma mensagem de resposta combinada contendo todas as respostas recebidas.
Antes de começar:
Para concluir esta tarefa, você deve ter concluído a seguinte tarefa:
Dependendo dos valores de tempo limite especificados, a mensagem de resposta combinada pode ser gerada antes da recepção de todas as respostas pelo fluxo de recepção.
Para rever um exemplo de um fluxo de recepção, consulte a amostra fornecida com o .
para criar o fluxo de recepção:
Esse deve ser um nó de entrada que suporta o modelo de pedido/resposta. Você pode utilizar os nós internos MQeInput e MQInput ou um nó de entrada definido pelo usuário que suporta pedido/resposta, ou uma mistura desses nós (dependendo dos requisitos dos aplicativos que enviam essas respostas). A resposta recebida por cada nó de entrada deve ser enviada pelo mesmo protocolo que o pedido ao qual ele corresponde (por exemplo, se você incluir um nó MQOutput no fluxo de difusão, a resposta para esse pedido deverá ser recebida por um nó MQInput nesse fluxo).
Isso representa a configuração mais simples; se apropriado, você pode incluir outros nós entre o nó de entrada e o nó AggregateReply. Por exemplo, talvez você queira armazenar as respostas para fins de auditoria (em um nó Warehouse).
Quando todas as respostas para um determinado grupo de pedidos de agregação tiverem sido coletadas, o nó AggregateReply criará uma mensagem de resposta agregada e a propagará através do terminal out.
O nó AggregateReply também recebe em seu terminal de controle a mensagem de controle que foi enviada pelo nó AggregateControl correspondente no fluxo de difusão (direta ou indiretamente, conforme descrito em Associando Fluxos de Agregação de Difusão e Recepção). Não modifique o conteúdo dessa mensagem de controle.
A estrutura da mensagem de resposta agregada que é propagada através do terminal de saída e as informações sobre como acessar seu conteúdo são fornecidas em Acessando o Conteúdo de Mensagens Combinadas.
O nó AggregateReply cria uma pasta na árvore de mensagens combinadas abaixo da Raiz, chamada ComIbmAggregateReplyBody. Abaixo disso, ele cria várias pastas utilizando os nomes de pastas definidos nos nós AggregateRequest. As mensagens de resposta associadas são colocadas abaixo delas.
Por exemplo, as mensagens de pedidos podem ter nomes de pastas:
A mensagem de resposta agregada resultante criada pelo nó AggregateReply poderá ter uma estrutura semelhante à mostrada abaixo:
Você pode utilizar um nó Compute para acessar a resposta da empresa de táxi utilizando o seguinte nome de correlação:
InputRoot.ComIbmAggregateReplyBody.TAXI.xyz
O nome da pasta não precisa ser exclusivo. Se você tiver vários pedidos com o nome de pasta TAXI, poderá acessar as respostas separadas utilizando a notação subscrita da matriz, por exemplo:
InputRoot.ComIbmAggregateReplyBody.TAXI[1].xyz InputRoot.ComIbmAggregateReplyBody.TAXI[2].xyz
Conceitos relacionados
Fluxos de Mensagem
Agregação de Fluxo de Mensagens
Nós Input definidos pelo usuário
Nós de Saída Definidos pelo Usuário
Tarefas relacionadas
Configurando Fluxos de Agregação
Criando o Fluxo de Difusão de Agregação
Associando Fluxos de Agregação de Difusão e Recepção
Definindo Tempos Limites para Agregação
Utilizando Vários Nós AggregateControl
Tratando Exceções e Conflitos do Banco de Dados em Fluxos de Agregação
Projetando um Fluxo de Mensagens
Criação de um Fluxo de Mensagens
Definindo o Conteúdo do Fluxo de Mensagens
Desenvolvendo Extensões Definidas pelo Usuário
Referências relacionadas
Nó AggregateControl
Nó AggregateReply
Nó AggregateRequest
Nó Compute
Nó MQeInput
Nó MQeOutput
Nó MQInput
Nó MQOutput
Avisos |
Marcas |
Downloads |
Biblioteca |
Suporte |
Feedback
![]() ![]() |
ac12300_ |