Você pode incluir mais de um nó de entrada em um único fluxo de mensagens.
Isso pode ser útil nas seguintes situações:
- O fluxo de mensagens fornece processamento comum para mensagens que são recebidas
a partir de vários transportes. Por exemplo, um único fluxo de
mensagens pode manipular:
- Os dados nas mensagens recebidas de WebSphere MQ
e, portanto, através de uma fila do WebSphere MQ e
um nó MQInput
- As mensagens que são recebidas de conexões IP nativas (um nó Real-timeInput)
- É necessário configurar propriedades padrão no nó MQInput
se as mensagens de entrada:
- forem predefinidas e
- são todas recebidas de WebSphere MQ e
- não incluírem um cabeçalho MQRFH2.
Se as propriedades
padrão requeridas nem sempre forem iguais para cada mensagem, será possível
incluir mais de um nó input e configurar cada um para tratar de um conjunto de
propriedades específico. Este requisito não é necessário
para mensagens de autodefinição.
- Cada nó input em um fluxo de mensagens faz com que o intermediário inicie um encadeamento de
execução separado. Incluir mais um nó input pode melhorar o
desempenho do fluxo de mensagens. No entanto, se você incluir
vários nós de entrada que acessam a mesma origem de entrada (por exemplo, uma fila do WebSphere MQ),
a ordem de processamento das mensagens não poderá ser garantida. Se desejar que o fluxo de mensagens processe mensagens na ordem em que elas são recebidas, essa opção não será apropriada.
Se você não estiver preocupado com a ordem das mensagens, considere a
utilização de instâncias adicionais do mesmo fluxo de mensagens em
vez de vários nós de entrada. Se você definir a propriedade Instâncias Adicionais
do fluxo de mensagens quando implementá-lo no intermediário, várias cópias
do fluxo de mensagens serão iniciadas no grupo de execução.
Esta é a forma mais eficiente
de tratar várias instâncias.
Veja a amostra a seguir:
Essa amostra utiliza dois nós de entrada: um nó
MQInput e um nó
Real-timeInput. Você
pode utilizar estes dois nós de entrada para ativar o fluxo de mensagens de amostra para aceitar
a entrada de transporte do WebSphere MQ e de conexões IP nativas.
Você
pode visualizar amostras apenas quando utilizar o centro de informações integrado
ao Message
Brokers Toolkit.