Crear el flujo de mensajes principal
Se proporciona el flujo de mensajes principal del ejemplo Manejador de errores, pero si prefiere crear el flujo de mensajes usted mismo, siga las instrucciones que se muestran a continuación.
Debe haber creado el subflujo de manejo de errores anteriormente para poder crear el flujo de mensajes principal, consulte
Crear el subflujo de manejo de errores.
- Cree un nuevo flujo de mensajes denominado Main_Flow en el proyecto de Message Broker Error Handler Message Flows que creó al crear el subflujo.
Para obtener instrucciones, consulte Crear un flujo de mensajes
en la documentación de WebSphere Message Broker.
- En el Editor de flujos de mensajes, añada y renombre los
nodos que se listan en la siguiente tabla.
Para obtener instrucciones, consulte Añadir un nodo en un flujo de mensajes
en la documentación de WebSphere Message Broker.
Cajones de la paleta |
Tipo de nodo |
Nombre de nodo |
WebSphere MQ |
MQInput |
STAFF_IN |
WebSphere MQ |
MQOutput |
STAFF_FAIL |
Direccionamiento |
Filter |
Check Valid Staff Number |
Database |
Database |
Update Staff Database |
Construcción |
Throw |
Throw |
WebSphere MQ |
MQOutput |
STAFF_OUT |
- Añada el subflujo al flujo de mensajes principal:
- Asegúrese de que el archivo Main_Flow.msgflow aparezca
en el editor de flujos de mensajes.
- Pulse con el botón derecho del ratón en el editor de flujo de mensajes y pulse
Añadir subflujo. Se abre la ventana Añadir subflujo.
- En la ventana Añadir Subflujo, expanda el proyecto Error Handler Message Flows, expanda (predeterminado), pulse _ handler msgflow, que es el archivo subflujo.
Pulse Aceptar.
- Un nodo llamado Error_Handler que representa al subflujo se añadirá al Editor de flujos de mensajes.
- Conecte los nodos tal como se indica en la siguiente tabla.
Para obtener instrucciones, consulte
Conexión a nodos de flujo de mensajes
en la documentación de WebSphere Message Broker.
Para comprobar que ha conectado los nodos correctamente, consulte el diagrama de Acerca del
ejemplo del Manejador de errores.
Nombre de nodo |
Terminal |
Conectar a este nodo |
STAFF_IN |
Out |
Error_Handler |
Failure (de anomalías) |
STAFF_FAIL |
Manejador de errores |
Out |
Check Valid Staff Number |
Check Valid Staff Number |
False |
Throw |
True |
Update Staff Database |
Update Staff Database |
Out |
STAFF_OUT |
Failure (de anomalías) |
STAFF_OUT |
- Configure las propiedades de nodo tal como se indica en la
siguiente tabla.
Acepte los valores predeterminados para todas las
propiedades, a menos que en la tabla se indique un valor alternativo.
Para obtener instrucciones, consulte
Configurar un nodo de flujo de mensajes
en la documentación de WebSphere Message Broker.
Nombre de nodo |
Página |
Propiedad |
Valor |
STAFF_IN |
Básicas |
Nombre de cola |
STAFF_IN |
Análisis de mensaje de entrada |
Dominio del mensaje |
XML : Para mensajes XML |
STAFF_FAIL |
Básicas |
Nombre de cola |
STAFF_FAIL |
Avanzadas |
Modalidad de transacción |
Sí |
Update Staff Database |
Básicas |
Origen de datos |
STAFFDB |
Throw |
Básicas |
Número del mensaje |
3001 |
Básicas |
Texto del mensaje |
Número de personal no válido |
STAFF_OUT |
Básicas |
Nombre de cola |
STAFF_OUT |
Avanzadas |
Modalidad de transacción |
Sí |
- En el proyecto Error Handler Message Flows,
efectúe una doble pulsación en el archivo Main_Flow.esql para abrirlo en el Editor ESQL.
Copie y pegue los siguientes módulos de código ESQL en el archivo
ESQL y luego guarde el archivo.
Para obtener más información, consulte
Desarrollo de ESQL
en la documentación de WebSphere Message Broker.
CREATE FILTER MODULE Main_Flow_Filter
CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN
If Body.Staff.StaffNumber<='10' THEN
RETURN TRUE;
ELSE
RETURN FALSE;
END IF;
END;
END MODULE;
CREATE DATABASE MODULE Main_Flow_Database
CREATE FUNCTION Main() RETURNS BOOLEAN
BEGIN
INSERT INTO Database.STAFF(STAFFNUM, LASTCHANGE, FIRSTNAME, LASTNAME)
VALUES(Body.Staff.StaffNumber, CURRENT_TIMESTAMP,
Body.Staff.NameInfo.FirstName, Body.Staff.NameInfo.LastName);
RETURN TRUE;
END;
END MODULE;
- Guarde el flujo de mensajes.
Volver a Crear el ejemplo de Manejador de errores