WebSphere Message Broker, Versão 8.0.0.5 Sistemas operacionais: AIX, HP-Itanium, Linux, Solaris, Windows, z/OS

Consulte as informações sobre a versão mais recente do produto em IBM Integration Bus, Versão 9.0

Collector

Utilize o nó Collector para criar coletas de mensagens baseadas em regras que você configura no nó.

Este tópico contém as seguintes seções:

Propósito

Utilize o nó Collector para criar uma coleta de mensagens a partir de uma ou mais origens baseadas em critérios configuráveis. Por exemplo, pode ser necessário extrair, combinar ou transformar informações de três origens diferentes. As mensagens destas origens diferentes podem chegar nos terminais de entrada em diferentes momentos e em uma ordem desconhecida. Uma coleta é definida pela configuração de um manipulador de eventos para cada terminal de entrada. Cada manipulador de evento controla a aceitação de uma mensagem em uma coleta de acordo com as seguintes propriedades:
  • Número de mensagens
  • Colete mensagens para um período definido
  • Corresponder o conteúdo de um caminho de correlação
  • Corresponder o conteúdo a um padrão de correlação
As propriedades de correlação permitem que as coletas sejam feitas de acordo com o conteúdo das mensagens. O conteúdo é especificado usando uma expressão XPath. O nó Collector garante que cada coleta contenha uma cadeia de correção idêntica em todas as suas entradas. Para obter informações adicionais sobre a sintaxe da consulta XPath 1.0, consulte Especificação de W3C XPath 1.0.

Uma coleta de mensagens é criada quando a primeira mensagem chega em qualquer dos terminais de entrada dinâmicos no nó Collector. As coletas de mensagens são armazenadas em uma fila do WebSphere® MQ.

Quando as condições configuradas pelos manipuladores de eventos para uma coleta de mensagens tiverem sido atendidas, a coleta de mensagens será concluída e estará pronta para ser propagada. Por exemplo, se você configurar os manipuladores de eventos no nó Collector para aguardar duas mensagens de cada terminal de entrada, a coleta de mensagens será concluída quando duas mensagens tiverem sido recebidas em cada terminal. Quando a próxima mensagem chega em um terminal de entrada, ela é incluída em uma nova coleta de mensagens. É possível selecionar a partir de uma série de opções para determinar como a propagação da coleta de mensagens é coordenada. É possível especificar se a coleta de mensagens é propagada automaticamente para processamento ou alternativamente se a coleta de mensagens é propagada quando uma mensagem de controle é recebida.

Também é possível configurar um tempo limite de expiração para coletas de mensagens que falham para serem concluídas em um tempo satisfatório usando uma propriedade no nó Collector. O tempo limite será iniciado quando a primeira mensagem for incluída em uma coleta de mensagens. Se o tempo limite expirar antes da coleta de mensagens ser concluída, a coleta de mensagens incompleta é propagada para o terminal Expiração. Configure um valor para a expiração da coleta para assegurar que as coletas de mensagens não concluídas não permaneçam armazenadas em uma fila indefinidamente. Inclua processamento apropriado em seu fluxo de mensagens para manipular coletas de mensagens não concluídas.

O nó Collector está contido no repositório do Roteamento da paleta do nó do fluxo de mensagens e é representado no WebSphere Message Broker Toolkit pelo seguinte ícone:

Ícone do nó Collector

Utilizando este nó em um fluxo de mensagens

Examine a amostra a seguir para ver como utilizar esse nó:

Você só pode visualizar informações sobre amostras quando usa o centro de informações que está integrado ao WebSphere Message Broker Toolkit ou o centro de informações on-line. Você só poderá executar amostras quando usar o centro de informações que está integrado ao WebSphere Message Broker Toolkit.

Use o nó Collector para agrupar mensagens de diferentes origens de entrada para processamento posterior. Uma coleta de mensagens pode ser processada apenas por um dos seguintes nós:
  • Compute
  • JavaCompute
  • .NETCompute
  • PHPCompute
Poderão ser gerados erros se você tentar processar uma coleta de mensagens com um nó que não suporta coletas de mensagens.

O nó Collector possui um terminal de entrada estático, Controle e quatro terminais de saída estáticos: Saída, Expiração, Falha e Captura. Estes terminais estáticos estão sempre presentes no nó. Além dos terminais de entrada e saída estáticos, você pode incluir terminais de entrada dinâmicos para cada origem de entrada que deseja utilizar com o nó Collector.

Você pode incluir e configurar quantos terminais de entrada forem necessários no nó Collector. É possível configurar as propriedades de cada terminal de entrada separadamente para controlar como as mensagens recebidas em cada terminal de entrada são incluídas na coleta de mensagens apropriada.

Você pode utilizar o terminal Controle para acionar a saída das coletas de mensagens completas a partir do nó Collector. Configure a propriedade Coordenação de Evento ou defina o comportamento do nó Collector quando as mensagens são recebidas no terminal Controle.

Quando uma coleta de mensagens é concluída com sucesso, ela está pronta para ser propagada para o terminal Saída. Se um valor maior que zero for configurado na propriedade Expiração da coleta, quaisquer coletas incompletas de mensagens serão propagadas no terminal Expiração.

Quando uma coleta de mensagens for concluída, uma nova transação será criada e propagada para o próximo nó. As exceções capturadas de nós de recebimento de dados causam a propagação da coleta de mensagens para o terminal Catch no nó Collector, juntamente com a lista de exceções. Se o terminal Captura não estiver conectado a nenhum outro nó, a transação será retornada. As mensagens na coleta de mensagens são restauradas para a fila no nóCollector. A lista de exceções é gravada no log do sistema. Esta etapa será repetida até que a coleta de mensagens tenha sido processada com êxito. Para evitar uma exceção que faça com que a coleta de mensagens falhe em ser propagada com êxito, certifique-se de conectar o terminal Captura a um fluxo para manipular todas as exceções. Além disso, certifique-se de que você configurou um tempo limite de expiração para propagar coletas de mensagens incompletas.

Nota: Quaisquer exceções que ocorram no recebimento de dados do nó Collector são roteadas para o terminal Captura. A exceção não é processada além do envio de dados, porque a conclusão da coleta de mensagens no nó Collector é o início da transação. Esse comportamento é como o nó AggregateReply. Não conecte um nó Throw ao terminal Captura do nó Collector , pois o controle retorna ao mesmo terminal Captura .

Se você utilizar instâncias adicionais de um fluxo de mensagens ou diversas entradas para o nó Collector, é possível utilizar as propriedades Caminho de Correlação e Padrão de Correlação para assegurar que as mensagens relacionadas sejam incluídas na mesma coleta de mensagens. Se você utilizar instâncias adicionais ou diversas entradas para o nó Collector, a ordem das mensagens na coleta de mensagens pode ser imprevisível. A ordem das mensagens também é imprevisível se você utilizar as filas de cluster do WebSphere MQ como entradas para o nó Collector.

Configurando o Nó Collector

Quando você tiver colocado uma instância do nó Collector em um fluxo de mensagens, você pode configurá-lo; consulte Configurando o Nó Collector e Configurando um Nó do Fluxo de Mensagens. As propriedades do nó são exibidas na visualização Propriedades. Todas as propriedades obrigatórias para as quais é necessário inserir um valor (as propriedades que não têm um valor-padrão definido) são marcadas com um asterisco.

Terminais e Propriedades

Os terminais do nó Collector são descritos na tabela a seguir.

Terminal Descrição
Control O terminal de entrada estático que aceita mensagens de controle. As mensagens recebidas pelo terminal Control são tratadas como uma mensagem de controle.
Out O terminal de saída para o qual a coleta de mensagens concluída será roteada se as mensagens recebidas atenderem as condições configuradas para a coleta de mensagens.
Expirar O terminal de saída para o qual a coleta de mensagens não concluída será roteada se as mensagens recebidas não atenderem as condições configuradas dentro do tempo especificado na propriedade Expiração da Coleta. Se você não tiver configurado um valor para a propriedade Expiração da Coleta, este terminal não será utilizado.
Falha O terminal de saída para o qual a coleta de mensagens será roteada se for detectada uma falha durante o processamento.
Catch O terminal de saída para o qual a coleta de mensagens será roteada se uma exceção no recebimento de dados for emitida e capturada por este nó.

O nó Collector pode ter terminais de entrada dinâmicos adicionais. É possível criar rótulos de terminal numérico para o nó Collector; entretanto, o nó Compute não suporta rótulos numéricos. Portanto, quando você estiver definindo um terminal customizado para o nó Collector, certifique-se de que o nome começa com um caractere alfanumérico.

As tabelas a seguir descrevem as propriedades do nó. A coluna com cabeçalho M indica se a propriedade é obrigatória (marcada com um asterisco caso seja necessário digitar um valor quando nenhum padrão for definido); a coluna com cabeçalho C indica se a propriedade é configurável (você poderá alterar o valor quando incluir o fluxo de mensagens ao arquivo BAR para implementá-lo).

As propriedades Descrição do nó Collector são descritas na tabela a seguir:

Propriedade M P Default Descrição
Nome do Nó Não Não O tipo de nó, Collector O nome do nó.
Descrição Breve Não Não   Uma breve descrição do nó.
Descrição Longa Não Não   Texto que descreve a finalidade do nó no fluxo de mensagens.

O nó Collector possui dois tipos de propriedades Básicas. Você pode configurar propriedades para cada terminal de entrada dinâmico incluído no nó Collector na tabela Definição de Coleta nas propriedades Básicas. As propriedades na tabela Definição de Coleta definem os manipuladores de eventos para as mensagens que chegam nos terminais de entrada individuais. As propriedades que podem ser configuradas para cada um dos terminais de entrada dinâmicos são descritas na tabela a seguir:

Propriedade M P Default Descrição
Terminal Sim Não O nome do terminal O Terminal não é uma propriedade do nó, mas um rótulo que mostra o nome do terminal de entrada dinâmico.

Digite valores para as propriedades do manipulador de eventos para cada terminal de entrada dinâmico incluído no nó Collector na tabela Definição de Coleta.

Quantidade Sim Não 1 Esta propriedade especifica o número de mensagens que o terminal de entrada aceita incluir em uma coleta de mensagens.

O valor padrão é 1; se você aceitar este valor padrão, apenas uma mensagem será incluída em uma coleta. Se uma segunda mensagem for recebida no terminal, uma nova instância da coleta será criada para ela. Se você selecionar 0 (zero) ou não especificar um valor, não haverá limite para o número de mensagens aceitas. Neste caso, o valor que é configurado na propriedade Tempo Limite deve ser maior que zero.

Timeout Sim Não 0 Esta propriedade especifica o tempo máximo em segundos durante o qual o terminal de entrada aceita mensagens. Se você selecionar 0 (zero), o tempo limite será desativado e não haverá limite no tempo de espera para mensagens. Neste caso, o valor que é configurado na propriedade Quantidade deve ser maior que zero.
Caminho da Correlação Não Não   As mensagens serão aceitas em uma coleta de mensagens apenas se tiverem a mesma cadeia de correlação. Se a mensagem tiver uma cadeia de correlação diferente, ela é oferecida para a próxima coleta da fila. Se nenhuma das coletas aceitar a mensagem, uma nova coleta será criada com a cadeia de correlação definida para o valor da cadeia de correlação na mensagem. As mensagens são agrupadas pelo valor do caminho de correlação. O caminho de correlação é definido pela utilização de XPath. É possível definir seu próprio caminho de correlação utilizando o XPath ou selecionar a partir dos seguintes caminhos predefinidos a seguir:
  • $LocalEnvironment/Wildcard/WildcardMatch
  • $Root/MQMD/CorrelId
  • $LocalEnvironment/FileInput/Name
  • $Root/JMSTransport/Transport_Folders/Header_Values/JMSCorrelationID

Se você definir um valor para Caminho de Correlação, opcionalmente, poderá configurar um Padrão de Correlação.

Padrão da Correlação Não Não   Esta propriedade especifica um padrão para corresponder ao conteúdo de um valor do caminho de correlação. Você deve configurar a propriedade Caminho de Correlação antes de configurar o valor para a propriedade Padrão de Correlação. Se você configurar o padrão de correlação, deverá utilizar um caractere *, opcionalmente, colocado entre outro texto. Por exemplo, *.dat.

Se o padrão de correlação estiver em branco, todo o texto do caminho de correlação deve ser correspondido pela mensagem de entrada.

As propriedades Básicas restantes para o nó Collector são mostradas na tabela a seguir:

Propriedade M P Default Descrição Propriedade do Comando mqsiapplybaroverride
Nome da coleta Não Não   Esta propriedade especifica o nome da coleta de mensagens.
  • Se você configurar esta propriedade para conter o curinga *, o curinga será substituído pela cadeia de correlação a partir do manipulador de eventos relevante.
  • Se você deixar esta propriedade em branco ou utilizar * e a cadeia de correlação estiver vazia, o nome da coleta será configurado como uma cadeia vazia.
 
Expiração da Coleta Não Sim   O período de tempo, em segundos, durante o qual o nó Collector aguarda a chegada de mensagens. Após esse tempo, uma coleta de mensagens incompleta expira e é propagada para o terminal de saída Expire.

Se você configurar esta propriedade como zero, a expiração da coleta será desativada e o nó do Collector aguardará as mensagens indefinidamente. Configure um valor maior do que zero para assegurar que a coleta de mensagens seja processada, mesmo que nem todas as mensagens tenham sido recebidas. Será emitido um aviso se esta propriedade não estiver configurada.

Esta propriedade é substituída pela propriedade Collection expiry, se configurada, no serviço configurável Coletor.

collectionExpiry

As propriedades Avançadas do nó Collector são descritas na tabela a seguir:

Propriedade M P Default Descrição
Modo de Persistência Não Não O tipo de nó, Collector Essa propriedade especifica se as mensagens são armazenadas nas filas do nó Collector de maneira persistente.
Coordenação de Eventos Sim Não Desativado Esta propriedade especifica como as mensagens recebidas no terminal Control para processamento de coordenação de evento são manipuladas no nó Collector.
  • Se você aceitar o valor padrão (Desativado), mensagens para o terminal de Controle serão ignoradas e coletas serão propagadas quando elas forem concluídas.
  • Se você selecionar Todas as Coletas Concluídas, as coletas de mensagens concluídas serão mantidas em uma fila do WebSphere MQ. Quando uma mensagem é recebida no terminal de controle, todas as coletas de mensagem concluídas na fila de WebSphere MQ são propagadas para o terminal de Saída.
  • Se você selecionar Primeira Coleta Concluída, as coletas de mensagens concluídas serão mantidas em uma fila do WebSphere MQ. Quando uma mensagem for recebida no terminal de controle, a primeira coleta de mensagens concluída na fila do WebSphere MQ será propagada para o terminal Out. As coletas são propagadas na mesma ordem que são concluídas. Se a fila de WebSphere MQ estiver vazia quando a mensagem for recebida no terminal de Controle, a próxima coleta de mensagem concluída será imediatamente propagada para o terminal de Saída.
Serviço configurável Não Sim Nenhum configurado Esta propriedade especifica o nome do serviço configurável Coletor a ser usado pelo nó Collector.

As propriedades configuradas pelo serviço configurável Coletor substituem as propriedades equivalentes configuradas no nó Collector.

Para obter informações adicionais sobre as propriedades que podem ser configuradas com esse serviço configurável, consulte Propriedades de Serviços Configuráveis.

As propriedades Monitoramento do nó são descritas na tabela a seguir.
Propriedade M P Default Descrição
Eventos Não Não Nenhum Eventos definidos para o nó são exibidos nesta guia. Por padrão, nenhum evento de monitoramento é definido em um nó do fluxo de mensagens. Utilize Incluir, Editar, e Excluir para criar, alterar ou excluir eventos de monitoração no nó; consulte Configurando fontes de eventos de monitoramento utilizando propriedades de monitoramento para detalhes.

É possível ativar e desativar eventos mostrados aqui selecionando ou desmarcando a caixa de opções Ativado.

Não é possível usar as propriedades de monitoramento para configurar eventos de transação nos seguintes nós: Use um perfil de monitoramento no lugar; consulte Configurando fontes de eventos de monitoramento utilizando um perfil de monitoramento.
Avisos | Marcas Registradas | Downloads | Biblioteca | Suporte | Feedback

Copyright IBM Corporation 1999, 2014Copyright IBM Corporation 1999, 2014.

        
        Última atualização:
        
        Última atualização: 2015-02-28 18:28:40


Tópico de ReferênciaTópico de Referência | Versão 8.0.0.5 | ac37820_