Você pode incluir mais de um nó de entrada em um único fluxo de mensagens.
Isso pode ser útil nas seguintes situações:
- Um fluxo de mensagens fornece processamento comum para mensagens que são recebidas
por meio de vários transportes. Por exemplo, um único fluxo de
mensagens pode manipular:
- Dados em mensagens recebidas por meio do
WebSphere MQ e portanto por meio de uma
fila do WebSphere MQ e de um nó MQInput
- Mensagens que são recebidas através de conexões IP nativas (um nó
Real-timeInput)
- Você precisará definir propriedades padrão no nó MQInput, se as
mensagens de entrada:
- forem predefinidas e
- se todas forem recebidas através do 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. Isso não é requerido
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.
O Amostra Scribble utiliza dois nós de entrada: um nó MQInput e um nó Real-timeInput. Isso permite que o fluxo de mensagens de amostra aceite entrada através de conexões de IP nativo e de transporte do WebSphere MQ.