En un mismo flujo de mensajes puede incluir más de un nodo de
entrada. Esto puede ser útil en las siguientes situaciones:
- El flujo de mensajes proporciona un proceso común de los mensajes que
se reciben a través de varios transportes. Por ejemplo, un solo flujo de
mensajes puede gestionar:
- Datos en mensajes recibidos a través de
WebSphere MQ y, por tanto, a través de una
cola de WebSphere MQ y un nodo MQInput
- Mensajes que se reciben a través de conexiones IP nativas (un nodo
Real-timeInput)
- Debe establecer propiedades estándar en el nodo MQInput si los
mensajes de entrada:
- están predefinidos y
- todos se reciben a través de WebSphere MQ y
- no incluyen una cabecera MQRFH2.
Si las propiedades estándar requeridas no son siempre las mismas para
todos los mensajes, puede incluir más de un nodo de entrada y configurar
cada uno para que maneje un conjunto específico de propiedades. Esto no es necesario para los mensajes autodefinidos.
- Cada nodo de entrada en un flujo de mensajes hace que el intermediario
empiece una hebra de ejecución aparte. La inclusión de más de un nodo de
entrada puede mejorar el rendimiento del flujo de mensajes. Sin
embargo, si incluye varios nodos de entrada que acceden al mismo origen de
entrada (por ejemplo, una cola de
WebSphere MQ), no se puede garantizar el
orden en que se procesarán los mensajes. Si desea que el flujo de mensajes
procese los mensajes en el orden en que se han recibido, esta opción no es
la adecuada.
Si no le importa el orden de los mensajes, piense en la
utilización de instancias adicionales del mismo flujo de mensajes
en lugar de varios nodos de entrada. Si establece la propiedad
Instancias adicionales
del flujo de mensajes cuando lo despliega al intermediario, se inician
varias copias del flujo de mensajes en el grupo de ejecución. Esta es la forma más eficaz de manejar varias instancias.
El Ejemplo Borrador utiliza dos nodos
de entrada: un nodo MQInput y un nodo Real-timeInput. Esto permite que el flujo de mensajes del
ejemplo acepte entrada a través de las conexiones IP nativas y de transporte de WebSphere MQ.