Acerca del ejemplo de Nodos CORBA

El ejemplo de Nodos CORBA está formado por varios flujos de procesos dentro de un flujo de mensajes. Estos flujos de procesos incluyen:

El siguiente diagrama de visión general muestra las relaciones que existen entre el flujo de mensajes de WebSphere Message Broker, el servicio de denominación y la aplicación Java de servidor CORBA.

Diagrama que muestra la relación entre Message Broker, el servicio de denominación y el servidor CORBA.

  1. El sistema de gestión del control de existencias está albergado como aplicación Java de servidor CORBA. La aplicación de servidor crea el objeto CORBA, lo enlaza con una referencia y coloca esta referencia de objeto en el servicio de denominación.
  2. En el momento del despliegue, el nodo CORBARequest se pone en contacto con el servicio de denominación para obtener una referencia de objeto. El servicio de denominación es el mecanismo que las aplicaciones de servidor CORBA utilizan para colocar sus referencias de objeto. El servicio de denominación se inicia en un nombre de host y un número de puerto específicos.
  3. El flujo de mensajes StockWarehouseClient conduce las solicitudes a la aplicación Java de servidor CORBA utilizando la referencia de objeto e invocando a la operación específica sobre el objeto en el servidor CORBA.

Direccionamiento de la solicitud de mensaje inicial

Este flujo de procesos consta de los siguientes nodos:

Diagrama de flujo para el proceso de la solicitud de mensaje inicial

El intermediario recibe una solicitud de mensaje de una cola de WebSphere MQ.

El nodo Compute:

  1. Establece el direccionamiento del mensaje especificando el nombre de etiqueta correcto al que debe direccionar en el entorno local.
  2. Copia el mensaje en el entorno local.

Creación de un proceso de artículo de existencias nuevo

Este flujo de procesos consta de los siguientes nodos:

Diagrama de flujo para el proceso de nuevos artículos de existencias

El nodo Label recibe la solicitud de mensaje direccionada. El nodo CORBARequest invoca la operación createNewStockItem de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta.

Un nodo Compute copia los datos de respuesta en el entorno local y establece los parámetros de entrada para la siguiente solicitud CORBA. El siguiente nodo CORBARequest invoca la operación setPrice de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta.

Un nodo Compute final copia los datos de respuesta en el entorno local, y luego copia todas las respuestas acumuladas de los nodos CORBARequest en el cuerpo del mensaje que se debe propagar a una cola de WebSphere MQ.

Las excepciones definidas por el usuario que se generan desde la aplicación Java de servidor CORBA se propagan desde el terminal de error del nodo CORBARequest a otra cola de WebSphere MQ.

Proceso de incremento de la cantidad de existencias

Este flujo de procesos consta de los siguientes nodos:

Diagrama de flujo para el proceso de incremento de la cantidad de existencias

El nodo Label recibe la solicitud de mensaje direccionada. El nodo CORBARequest invoca la operación addStock de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta que se propaga a una cola de WebSphere MQ.

Las excepciones definidas por el usuario que se generan desde la aplicación Java de servidor CORBA se propagan desde el terminal de error del nodo CORBARequest a otra cola de WebSphere MQ.

Proceso de obtención de detalles de artículos de existencias

Este flujo de procesos consta de los siguientes nodos:

Diagrama de flujo para el proceso de obtención de detalles de artículos de existencias

El nodo Label recibe la solicitud de mensaje direccionada. El nodo CORBARequest invoca la operación getSKU de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta.

Un nodo Compute copia los datos de respuesta en el entorno local y establece los parámetros de entrada para la siguiente solicitud CORBA. El siguiente nodo CORBARequest invoca la operación getPrice de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta.

Otro nodo Compute copia los datos de respuesta en el entorno local y establece los parámetros de entrada para la siguiente solicitud CORBA. El siguiente nodo CORBARequest invoca la operación getStockLevel de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta.

Un nodo Compute final copia los datos de respuesta en el entorno local, y luego copia todas las respuestas acumuladas de los nodos CORBARequest en el cuerpo del mensaje que se debe propagar a una cola de WebSphere MQ.

Las excepciones definidas por el usuario que se generan desde la aplicación Java de servidor CORBA se propagan desde el terminal de error del nodo CORBARequest a otra cola de WebSphere MQ.

Proceso de reducción de la cantidad de existencias

Este flujo de procesos consta de los siguientes nodos:

Diagrama de flujo para el proceso de reducción de la cantidad de existencias

El nodo Label recibe la solicitud de mensaje direccionada. El nodo CORBARequest invoca la operación reduceStock de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta que se propaga a una cola de WebSphere MQ.

Las excepciones definidas por el usuario que se generan desde la aplicación Java de servidor CORBA se propagan desde el terminal de error del nodo CORBARequest a otra cola de WebSphere MQ.

Proceso de supresión de un artículo de existencias

Este flujo de procesos consta de los siguientes nodos:

Diagrama de flujo para el proceso de supresión de artículo de existencias

El nodo Label recibe la solicitud de mensaje direccionada. El nodo CORBARequest invoca la operación deleteStockItem de la aplicación de servidor CORBA que pasa los parámetros de entrada y devuelve una respuesta que se propaga a una cola de WebSphere MQ.

Las excepciones definidas por el usuario que se generan desde la aplicación Java de servidor CORBA se propagan desde el terminal de error del nodo CORBARequest a otra cola de WebSphere MQ.

Volver a la página inicial del ejemplo