Nodo MQeInput

Este tema contiene los apartados siguientes:

Finalidad

Utilice el nodo MQeInput para recibir mensajes de clientes que se conectan al intermediario utilizando el protocolo WebSphere MQ Mobile Transport.

El nodo MQeInput recibe mensajes que se han transferido a un flujo de mensajes de una cola puente especificada a un gestor de colas WebSphere MQ Everyplace del intermediario. El nodo también establece el entorno de proceso para los mensajes. Debe crear y configurar el flujo de mensajes WebSphere MQ Everyplace antes de difundir un flujo de mensajes que contenga este nodo.

Los flujos de mensajes que manejan mensajes recibidos a través de conexiones WebSphere MQ Everyplace siempre se deben iniciar con un nodo MQeInput. Puede establecer las propiedades del nodo MQeInput para controlar el modo en el que se reciben los mensajes, por ejemplo, puede indicar que un mensaje se debe procesar bajo control de transacción.

Cuando difunde flujos de mensajes que contienen nodos WebSphere MQ Everyplace a un intermediario, debe difundirlos a un único grupo de ejecución, sin tener en cuenta el número de flujos de mensajes. Todos los nodos WebSphere MQ Everyplace de los flujos deben especificar el mismo nombre de gestor de colas WebSphere MQ Everyplace. Si no se cumple esta restricción, se emite un error durante la difusión.

El nodo MQeInput maneja mensajes en los dominios de mensajes siguientes:

  • MRM
  • XML
  • XMLNS
  • JMSMap
  • JMSStream
  • BLOB

Si incluye un nodo de salida en un flujo de mensajes que se inicia con un nodo MQeInput, puede ser cualquiera de los nodos de salida para los que se ofrece soporte (incluidos los nodos de salida definidos por el usuario): no es necesario que incluya el nodo MQeOutput. Puede crear un flujo de mensajes que reciba mensajes de clientes WebSphere MQ Everyplace y genere mensajes para clientes que utilicen todos los transportes para los que se ofrece soporte para conectar al intermediario, puesto que puede configurar el flujo de mensajes de modo que solicite al intermediario que facilite las conversiones necesarias.

WebSphere Business Integration Message Broker utiliza WebSphere MQ Everyplace Versión 1.2.6, siendo compatible con versiones posteriores de WebSphere MQ Everyplace. Los clientes que utilizan versiones posteriores de WebSphere MQ Everyplace, por ejemplo, la Versión 2.0, funcionan correctamente cuando se conectan a este nodo, aunque las funciones adicionales para las que no se ofrece soporte en la Versión 1.2.6 (por ejemplo, soporte JMS) no funcionan.

Los gestores de colas no se pueden intercambiar entre versiones diferentes de WebSphere MQ Everyplace. Los nodos deben utilizar un gestor de colas que se haya creado utilizando la Versión 1.2.6. Del mismo modo, el cliente debe utilizar su nivel de código al crear un gestor de colas.

No puede utilizar nodos MQeInput en flujos de mensajes que se van a difundir a sistemas z/OS.

Si crea un flujo de mensajes para utilizarlo como un subflujo, no puede utilizar un nodo de entrada estándar: debe utilizar una instancia del nodo Input como primer nodo para crear un terminal de entrada para el subflujo.

Si el flujo de mensajes no recibe mensajes a través de conexiones WebSphere MQ, puede elegir uno de los nodos de entrada que se indican a continuación:

  • HTTPInput
  • MQInput
  • Real-timeInput
  • SCADAInput
  • Un nodo de entrada definido por el usuario

El nodo MQeInput se representa en el área de trabajo mediante el icono siguiente:

icono del nodo MQeInput

Utilización de este nodo en un flujo de mensajes

Como ejemplo sobre cómo se puede utilizar este nodo, suponga que un agricultor inspecciona sus campos para comprobar si se riegan correctamente. Lleva consigo un dispositivo PDA con WebSphere MQ Everyplace instalado. Observa que un área del campo precisa agua, de modo que, utilizando el PDA y un enlace de navegación global por satélite (Global Satellite Navigation), envía un mensaje a un nodo MQeInput. Los datos se manipulan utilizando un nodo Compute y el nodo Publication publica un mensaje de modo que el dispositivo SCADA remoto pueda recoger el mensaje y activar los aspersores de riego. El agricultor puede ver cómo se riega el campo minutos después de enviar el mensaje.

Documentación de WebSphere MQ Everyplace

Puede obtener información detallada sobre WebSphere MQ Everyplace y las propiedades del nodo, en la documentación de WebSphere MQ Everyplace que se facilita en la página Web de WebSphere MQ.

Configuración del nodo MQeInput

Se puede configurar al transferir una instancia del nodo MQeInput a un flujo de mensajes. Pulse el botón derecho del ratón en la vista del editor y, a continuación, pulse en Propiedades. Las propiedades por omisión del nodo se muestran en el diálogo de propiedades.

Todas las propiedades obligatorias para las que debe entrar un valor (las que no tienen un valor por omisión definido) se muestran marcadas con un asterisco en el diálogo de propiedades.

Configure el nodo MQeInput tal como se indica a continuación:

  1. Seleccione Valor por omisión en el navegador del diálogo de propiedades y establezca valores para las propiedades que describen el dominio de mensajes, el conjunto de mensajes, el tipo de mensaje y el formato del mensaje que utiliza el nodo para determinar cómo analizar el mensaje entrante y el tema por omisión asociado al mensaje.
    • Si el mensaje entrante tiene una cabecera MQRFH2, no es necesario que establezca valores para las propiedades por omisión, puesto que los valores se pueden derivar de la carpeta <mcd> de la cabecera MQRFH2. Por ejemplo:
      <mcd><Msd>MRM</Msd><Set>DHM4UO906S001</Set><Type>receiptmsg1</Type>
      <Fmt>XML</Fmt></mcd>

      Si establece valores, y los valores difieren de los de la cabecera MQRFH2, los valores de la cabecera MQRFH2 tienen prioridad.

    • En Dominio del mensaje, seleccione el nombre del analizador que está utilizando de la lista desplegable. Puede elegir entre:
      • MRM
      • XML
      • XMLNS
      • JMSMap
      • JMSStream
      • BLOB
    • Si utiliza el analizador MRM, seleccione el conjunto de mensajes correcto de la lista desplegable de Conjunto de mensajes. Esta lista se llena con los conjuntos de mensajes disponibles cuando se seleccione MRM como dominio.

      Deje Conjunto de mensajes en blanco para los analizadores XML, XMLNS, JMS y BLOB.

    • Si utiliza el analizador MRM, seleccione el mensaje correcto de la lista desplegable de Tipo de mensaje. Esta lista se llena con los mensajes que se definen en el conjunto de mensajes que se ha seleccionado.

      Deje Tipo de mensaje en blanco para los analizadores XML, XMLNS, JMS y BLOB.

    • Seleccione el formato del mensaje de la lista desplegable de Formato del mensaje. Esta lista incluye todos los formatos físicos que se han definido para este conjunto de mensajes. Si ha utilizado los nombres por omisión para los formatos físicos, la lista contiene:
      • CWF1 (el ID del formato físico personalizado por omisión)
      • XML1
      • TDS1
      Si ha especificado nombres diferentes (que no son por omisión) para cualquiera de estos formatos, los nombres aparecen en la lista.

      Deje Formato del mensaje en blanco para los analizadores XML, XMLNS, JMS y BLOB.

    • Indique el tema del mensaje en Tema. Puede entrar cualquier carácter para el nombre del tema. Cuando los mensajes pasan a través del nodo MQeInput, dan por supuesto cualquier nombre que se haya especificado. (Si utiliza publicación/suscripción, se puede suscribir a un tema y ver todos los mensajes que se han pasado a través del nodo MQeInput con el nombre del tema).
  2. Seleccione General en el navegador del diálogo de propiedades y complete las propiedades siguientes:
    1. Especifique el Nombre de cola de la cola puente de WebSphere MQ Everyplace de la que recupera los mensajes este nodo de entrada. Si la cola no existe, se crea automáticamente al difundir el flujo de mensajes al intermediario.
    2. Establezca el nivel de Rastreo que desea para este nodo. Si el rastreo está activo, la información de rastreo se registra en el archivo identificado en Nombre archivo rastreo (descrito más abajo). Elija uno de los siguientes:
      • Ninguno. Éste es el valor por omisión. No se produce ninguna salida de rastreo, a menos que se produzca un error muy grave.
      • Estándar. Se genera una salida de rastreo mínima para reflejar las operaciones globales del nodo.
      • Depurar. Se registra información de rastreo a un nivel que le ayuda a depurar programas de WebSphere MQ Everyplace.
      • Completo. Se registra toda la información de depuración disponible para proporcionar un registro completo de las actividades del nodo.

      Si establece el nivel de rastreo en Depurar o Completo, puede afectar al rendimiento de WebSphere MQ Everyplace, además de generar archivos de rastreo de gran tamaño. Utilice estas opciones sólo durante períodos breves de tiempo.

    3. En Nombre archivo rastreo, especifique el nombre del archivo en el que se debe escribir la información de rastreo. La estructura de directorios en la que se especifica el archivo debe existir previamente: no se puede crear durante la operación.
    4. Seleccione la Modalidad de transacción para definir las características transaccionales sobre el manejo de este mensaje:
      • Si selecciona Automática, el mensaje entrante se recibe bajo punto de sincronismo si se ha marcado como permanente; de lo contrario, no. La propiedad de permanencia de entrada determina la transaccionalidad de todos los mensajes derivados que envía con posterioridad un nodo de salida, a menos que se haya alterado temporalmente de forma explícita la transaccionalidad del nodo de salida.
      • Si selecciona , el mensaje entrante se recibe bajo punto de sincronismo. Todos los mensajes derivados que envía posteriormente un nodo de salida de la misma instancia del flujo de mensajes se envían de modo transaccional, a menos que el nodo de salida haya alterado temporalmente de forma explícita la transaccionalidad.
      • Si selecciona No, el mensaje entrante no se recibe bajo punto de sincronismo. Todos los mensajes derivados que envía posteriormente un nodo de salida del flujo se envían sin transaccionalidad, a menos que el nodo de salida haya especificado que el mensaje se debe transferir bajo punto de sincronismo.
    5. Por omisión, el recuadro de selección Utilizar archivo config. no aparece seleccionado: los valores de todas las propiedades del nodo MQeInput se toman del diálogo de propiedades.

      Si selecciona el recuadro de selección, la definición de todas las propiedades se extrae del archivo que se identifica en Nombre archivo config. (descrito más abajo) excepto en los casos siguientes:

      • Las propiedades generales de Nombre de cola y Nombre archivo config.
      • Todas las propiedades por omisión
      Utilice un archivo de configuración sólo para especificar propiedades adicionales para el nodo. Si las propiedades del diálogo de propiedades son suficientes para sus necesidades, no seleccione el recuadro de selección Utilizar archivo config..
    6. Si ha seleccionado el recuadro de selección Utilizar archivo config., especifique la vía de acceso y el nombre completos del archivo de configuración para WebSphere MQ Everyplace en Nombre archivo config.. Este archivo se debe instalar en el sistema que ofrece soporte para todos los intermediarios a los que se difunde el flujo de mensajes. Si el archivo no existe, se detecta un error al difundir el flujo de mensajes. El nombre de archivo por omisión es MQeConfig.ini.
    7. En Nombre del gestor de colas, especifique el nombre del gestor de colas de WebSphere MQ Everyplace. No está relacionado con el gestor de colas del intermediario al que se difunde el flujo de mensajes que contiene el nodo.

      Sólo se ofrece soporte para un gestor de colas de WebSphere MQ Everyplace. Sólo un grupo de ejecución puede contener nodos MQeInput o MQeOutput. Por consiguiente, esta propiedad se debe establecer en el mismo valor en cada uno de los nodos MQeInput incluidos en todos los flujos de mensajes que se difunden al mismo intermediario.

  3. Seleccione Canal en el navegador del diálogo de propiedades y establezca el número máximo de canales para los que ofrece soporte WebSphere MQ Everyplace en Máximo de canales. El valor por omisión es es cero, lo que significa que no existe ningún límite.
  4. Seleccione Registro en el navegador del diálogo de propiedades y complete las propiedades siguientes:
    1. Seleccione el tipo de registro de la lista desplegable de la propiedad Tipo de registro. Puede elegir uno de los siguientes:
      • Registro de archivo. La información de registro y seguridad se proporciona en el Directorio que se especifica más abajo.
      • Registro privado. El gestor de colas se crea manualmente en WebSphere MQ Everyplace, especificando los parámetros de seguridad necesarios.
    2. En Directorio, especifique el directorio donde se encuentra el archivo de registro. Sólo es válido si se ha seleccionado un Tipo de registro de Registro de archivo.
    3. Si ha seleccionado un Tipo de registro de Registro privado, complete las propiedades siguientes:
      • Especifique un PIN para el gestor de colas asociado. Para obtener información detallada, consulte la documentación de WebSphere MQ Everyplace.
      • Especifique un PIN de certificado para las peticiones de autentificación. Para obtener información detallada, consulte la documentación de WebSphere MQ Everyplace.
      • Proporcione una Contraseña del archivo de claves a fin de utilizarla como semilla para la generación de claves criptográficas. Para obtener información detallada, consulte la documentación de WebSphere MQ Everyplace.
      • En Sistema principal de certificados, especifique el nombre del servidor de certificados que utiliza WebSphere MQ Everyplace para la autentificación. Para obtener información detallada, consulte la documentación de WebSphere MQ Everyplace.
      • En Puerta de certificados, especifique el número de la puerta del servidor de certificados que utiliza WebSphere MQ Everyplace para la autentificación. Para obtener información detallada, consulte la documentación de WebSphere MQ Everyplace.
  5. Seleccione Escucha en el navegador del diálogo de propiedades y complete las propiedades siguientes que definen el tipo de conexión para WebSphere MQ Everyplace:
    1. En Tipo de escucha, seleccione el tipo de adaptador que desea utilizar de la lista desplegable. El valor por omisión es es Http; también puede seleccionar Longitud o Historia. Para obtener información detallada, consulte la documentación de WebSphere MQ Everyplace.
    2. En nombre del sistema principal, especifique el nombre del sistema principal del servidor. Establézcalo en el valor especial sistemaPrincipalLocal, o bien, en la dirección TCP/IP 127.0.0.1 (el valor por omisión). Ambos se resuelven correctamente para el nombre del sistema principal del servidor al que se difunde el flujo de mensajes. También puede utilizar cualquier nombre del sistema principal o dirección TCP/IP válida, pero debe utilizar un flujo de mensajes diferente para cada intermediario al que lo difunde o configurar esta propiedad en el momento de la difusión.
    3. En Puerta, especifique el número de puerta desde la que WebSphere MQ Everyplace está a la escucha. Si se ha incluido más de un nodo MQeInput en un flujo de mensajes difundido a un único intermediario, cada nodo MQeInput debe especificar un número diferente para esta propiedad. También debe asegurarse de que el número que especifica no entra en conflicto con otros escuchas del sistema del intermediario, por ejemplo, con WebSphere MQ. El valor por omisión es 8081.
    4. En Intervalo de tiempo, especifique el valor de tiempo de espera en segundos antes de que los canales desocupados excedan el tiempo de espera. El valor por omisión son de 300 segundos.

      Puesto que los canales son entidades lógicas permanentes cuya duración es superior a la de una sola petición del gestor de colas, y pueden perdurar a interrupciones de la red, es posible que sea necesario que se exceda el tiempo de espera de los canales que han estado inactivos durante un período de tiempo determinado.

  6. Seleccione Descripción en el navegador del diálogo de propiedades para especificar una descripción corta, una descripción larga, o ambas.
  7. Pulse el botón en Aplicar para realizar los cambios en el nodo MQeInput sin cerrar el diálogo de propiedades. Pulse el botón en Aceptar para aplicar los cambios y cerrar el diálogo de propiedades.

    Pulse el botón en Cancelar para cerrar el diálogo y descartar todos los cambios que ha realizado en las propiedades.

Conexión de terminales

MQeInput direcciona cada mensaje que recupera correctamente al terminal de salida. Si no se ejecuta correctamente, se reintenta el mensaje. Si el tiempo de espera de reintento caduca (tal como lo define el atributo BackoutThreshold de la cola de entrada), el mensaje se direcciona al terminal de anomalías; puede conectar nodos a este terminal para manejar esta condición. Si no ha conectado el terminal de anomalías, el mensaje se escribe en la cola de restitución.

Si el nodo capta el mensaje después de emitirse una excepción más adelante en el flujo de mensajes, el mensaje se direcciona al terminal de captación. Si no ha conectado el terminal de captación, el mensaje se repite continuamente en bucle a través del nodo hasta que se resuelve el problema. Debe definir una cola de restitución o una cola de mensajes no entregados (DLQ) a fin de evitar que el mensaje se repita en bucle de forma continuada a través del nodo.

Configuración de transacciones coordinadas

Cuando incluye un nodo MQeInput en un flujo de mensajes, el valor que se establece para la propiedad Modalidad de transacción define si los mensajes se deben recibir bajo punto de sincronismo.

  • Si lo establece en (el valor por omisión), el mensaje se recibe bajo punto de sincronismo (es decir, en una unidad de trabajo de WebSphere MQ). Todos los mensajes que envía con posterioridad un nodo de salida en la misma instancia del flujo de mensajes se transfieren bajo punto de sincronismo, a menos que el nodo de salida lo haya alterado temporalmente de forma explícita.
  • Si lo establece en Automático, el mensaje se recibe bajo punto de sincronismo en caso de que el mensaje entrante se haya marcado como permanente. De lo contrario, no. Todos los mensajes que envía con posterioridad un nodo de salida se transfieren bajo punto de sincronismo, tal como lo determina la propiedad de permanencia entrante, a menos que el nodo de salida lo haya alterado temporalmente de forma explícita.
  • Si lo establece en No, el mensaje no se recibe bajo punto de sincronismo. Todos los mensajes que envía con posterioridad un nodo de salida del flujo no se transfieren bajo punto de sincronismo, a menos que un nodo de salida individual haya especificado que el mensaje se debe transferir bajo punto de sincronismo.

(El nodo MQOutput es el único nodo de salida que se puede configurar para alterar temporalmente esta opción).

Terminales y propiedades

Los terminales del nodo MQeInput se describen en la tabla siguiente:

Terminal Descripción
Terminal de anomalías Terminal de salida al que se direcciona el mensaje si se produce un error.
Terminal de salida Terminal de salida al que se direcciona un mensaje si se recupera correctamente de la cola de WebSphere MQ Everyplace.
Terminal de captación Terminal de salida al que se direcciona el mensaje si se emite una excepción en sentido descendente y la captura este nodo.

En las tablas siguientes se describen las propiedades del nodo; la columna que tiene el encabezamiento M indica si se trata de una propiedad obligatoria (marcada con un asterisco en el diálogo de propiedades si se debe especificar un valor cuando no se ha definido ningún valor por omisión), la columna que tiene el encabezamiento C indica que se trata de una propiedad configurable (se puede cambiar el valor cuando se añade el flujo de mensajes al archivo bar para su difusión).

Las propiedades por omisión del nodo MQeInput se describen en la tabla siguiente:

Propiedad M C Valor por omisión Descripción
Dominio del mensaje No No   Dominio del mensaje entrante.
Conjunto de mensajes No No   Conjunto de mensajes del mensaje entrante.
Tipo de mensaje No No   Tipo del mensaje entrante.
Formato del mensaje No No   Formato del mensaje entrante.
Tema No   Tema por omisión para el mensaje de entrada.

Las propiedades generales del nodo MQeInput se describen en la tabla siguiente:

Propiedad M C Valor por omisión Descripción
Nombre de cola   Nombre de la cola puente de WebSphere MQ Everyplace desde la que el nodo recupera mensajes para que los procese el flujo de mensajes.
Rastreo No Ninguno Nivel de rastreo que se necesita para este nodo. Los valores válidos son Ninguno, Estándar, Depurar y Completo.
Nombre archivo rastreo \MQeTraceFile.trc Nombre del archivo en el que se escriben los registros de rastreo.
Modalidad de transacción No Si el mensaje entrante se recibe bajo punto de sincronismo. Los valores válidos son Automático, y No.
Utilizar archivo config. No Deseleccionado Utilizar un archivo de configuración para este nodo. Si selecciona el recuadro de selección, se realiza esta acción.
Nombre archivo config. \MQeconfig.ini Nombre del archivo de configuración que se debe utilizar si se selecciona el recuadro de selección Utilizar archivo config..
Nombre del gestor de colas ServerQM1 Nombre del gestor de colas de WebSphere MQ Everyplace.

Las propiedades de canal del nodo MQeInput se describen en la tabla siguiente:

Propiedad M C Valor por omisión Descripción
Máximo de canales No 0 Número máximo de canales para los que ofrece soporte el gestor de colas de WebSphere MQ Everyplace.

Las propiedades de registro del nodo MQeInput se describen en la tabla siguiente:

Propiedad M C Valor por omisión Descripción
Tipo Registro de archivo Tipo de información de registro que se va a utilizar. Los valores válidos son Registro de archivo y Registro privado.
Directorio \ServerQM1\registry Directorio en el se encuentra el archivo de registro (válido sólo si se ha seleccionado Registro de archivo).
PIN   PIN asociado al gestor de colas de WebSphere MQ Everyplace (válido sólo si se ha seleccionado Registro privado).
PIN de petición de certificado   PIN que se utiliza para solicitar autentificación (válido sólo si se ha seleccionado Registro privado).
Contraseña del archivo de claves   Contraseña que se utiliza para ver claves criptográficas (válido sólo si se ha seleccionado Registro privado).
Sistema principal de certificados   Nombre del servidor de certificados (válido sólo si se ha seleccionado Registro privado).
Puerta de certificados   Puerta del servidor de certificados (válido sólo si se ha seleccionado Registro privado).

Las propiedades de escucha del nodo MQeInput se describen en la tabla siguiente:

Propiedad M C Valor por omisión Descripción
Tipo Http Tipo de adaptador para el escucha. Los valores válidos son Http, Longitud, y Historia.
Nombre del sistema principal 127.0.0.1 Nombre del sistema principal del servidor.
Puerta 8081 Puerta en la que WebSphere MQ Everyplace está a la escucha.
Intervalo de tiempo 300 Intervalo de sondeo de WebSphere MQ Everyplace, especificado en segundos.

Las propiedades de descripción del nodo MQeInput se describen en la tabla siguiente:

Propiedad M C Valor por omisión Descripción
Descripción corta No No   Descripción breve del nodo.
Descripción larga No No   Texto que describe la finalidad del nodo en el flujo de mensajes.

Conceptos relacionados
Flujos de mensajes
WebSphere MQ Mobile Transport
Extensiones definidas por el usuario
Difusión de aplicaciones de flujos de mensajes

Tareas relacionadas
Trabajo con casos de WebSphere MQ Everyplace de ejemplo
Cómo decidir los nodos que utilizar
Utilización de más de un nodo de entrada
Utilización de colas de clúster WebSphere MQ para entrada y salida
Utilización de colas compartidas de WebSphere MQ para entrada y salida (z/OS)
Configuración de flujos de mensajes coordinados
Manejo de errores en flujos de mensajes
Validación de mensajes
Definición de las limitaciones de valores
Edición de propiedades configurables

Referencia relacionada
WebSphere MQ Mobile Transport
Nodo MQInput
Nodo SCADAInput
Nodo Input
Nodo HTTPInput
Nodo Real-timeInput
Nodo MQeOutput