Colas De Mensajes Con AquaLogic

Vamos a exponer con AquaLogic un Web Service que nos permita enviar un mensaje a una cola de mensajería. Partimos de un WSDL en donde definimos una operación “enviarFactura” que recibe como parámetro un elemento de tipo factura. Los elementos y tipos de dato de una factura se encuentran definidos en el esquema xml asociado al WSDL.

La definición del servicio

Wsdl

<?xml version="1.0" encoding="UTF-8"?> <definitions name="facturaWsdl" targetNamespace="http://j2ee.netbeans.org/wsdl/facturaWsdl"

   xmlns="http://schemas.xmlsoap.org/wsdl/"
   xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/"
   xmlns:xsd="http://www.w3.org/2001/XMLSchema" 
   xmlns:tns="http://j2ee.netbeans.org/wsdl/facturaWsdl" 
   xmlns:ns="http://xml.netbeans.org/schema/facturaXmlSchema" 
   xmlns:soap="http://schemas.xmlsoap.org/wsdl/soap/">

   <types>
       <xsd:schema targetNamespace="http://j2ee.netbeans.org/wsdl/facturaWsdl">
           <xsd:import namespace="http://xml.netbeans.org/schema/facturaXmlSchema" 
                       schemaLocation="../schema/facturaXmlSchema.xsd"/>
       </xsd:schema>
   </types>
   <message name="enviarFacturaRequest">
       <part name="part1" element="ns:factura"/>
   </message>
   <message name="enviarFacturaResponse"/>
   <portType name="facturaWsdlPortType">
       <operation name="enviarFactura">
           <input name="input1" message="tns:enviarFacturaRequest"/>
           <output name="output1" message="tns:enviarFacturaResponse"/>
       </operation>
   </portType>
   <binding name="facturaWsdlBinding" type="tns:facturaWsdlPortType">
       <soap:binding style="document" transport="http://schemas.xmlsoap.org/soap/http"/>
       <operation name="enviarFactura">
           <soap:operation/>
           <input name="input1">
               <soap:body use="literal"/>
           </input>
           <output name="output1">
               <soap:body use="literal"/>
           </output>
       </operation>
   </binding>
   <service name="facturaWsdlService">
       <port name="facturaWsdlPort" binding="tns:facturaWsdlBinding">
           <soap:address 
       location="http://localhost:${HttpDefaultPort}/facturaWsdlService/facturaWsdlPort"/>
       </port>
   </service>

</definitions>

El Esquema XML (XSD)

<?xml version="1.0" encoding="UTF-8"?>

<xsd:schema xmlns:xsd="http://www.w3.org/2001/XMLSchema"

   targetNamespace="http://xml.netbeans.org/schema/facturaXmlSchema"
   xmlns:tns="http://xml.netbeans.org/schema/facturaXmlSchema"
   elementFormDefault="qualified">
       
   <xsd:element name="factura">
       <xsd:complexType>
           <xsd:sequence>
               <xsd:element name="numeroFactura" type="xsd:string"/>
               <xsd:element name="fecha" type="xsd:string"/>
               <xsd:element name="items" type="tns:listaItemsFactura"/>
           </xsd:sequence>
       </xsd:complexType>
   </xsd:element>
   
   <xsd:complexType name="itemFactura">
       <xsd:all>
           <xsd:element name="codigoArticulo" type="xsd:string"/>
           <xsd:element name="descripcion" minOccurs="0" type="xsd:string"/>
           <xsd:element name="cantidad" type="xsd:int"/>
           <xsd:element name="precio" type="xsd:double"/>
       </xsd:all>
   </xsd:complexType>
   
   <xsd:complexType name="listaItemsFactura">
       <xsd:sequence>
           <xsd:element name="item" maxOccurs="unbounded" type="tns:itemFactura"/>
       </xsd:sequence>
   </xsd:complexType>
   

</xsd:schema>

Creación del proyecto

Recordemos que para crear objetos y/o modificarlos en AquaLogic se debe crear una sesión y luego activar la misma para que los cambios tengan efecto.

Desde la consola de aqualogic, en el Project Explorer creamos un proyecto llamado "demoFactura":

Para ser ordenados, dentro del proyecto demoFactura creamos una carpeta “envío de facturas”, donde crearemos todos los recursos de esta demo.

Agregamos el Esquema XML (XSD)

Para subir el esquema XML al AquaLogic, dentro de nuestra carpeta elegimos la opción XML Schema en el combo “Create Resource:”

Le ponemos un nombre al recurso que estamos creando y cargamos el archivo de definición de una factura.

Después de hacer click en Save vemos que tenemos el archivo xsd cargado correctamente:

Agregamos el WSDL

Para cargar el wsdl seguimos los mismos pasos que en el apartado anterior, eligiendo en el combo “Create Resource:” la opción WSDL.

Después de dar un nombre al recurso, cargar el archivo .wsdl y guardar los cambios tendremos:

Creamos un Business Service

El business service será el responsable de enviar el mensaje a la queue. Si elegimos la opción “Business Service” del combo “Create Resource” ingresamos al wizard para configurar este servicio. En el primer paso damos un nombre al servicio e indicamos que es de tipo “Messaging Service”.

Seteamos request y response como texto:

Marcamos que se utilizará el protocolo jms y agregamos con el botón Add los destinos del mensaje. El formato de las uri es jms://<host>:<puerto>/<jndi-connection-factory>/<jndi-queue> (Si nuestros jndi contienen “/”, las escapeamos con “.”)

Indicamos que el destinatario es una queue y que se enviará un text message.

En el último paso del wizard verificamos toda la información ingresada y guardamos los cambios. Entonces ya podemos probar el bussinessService mediante el ícono de “Launch Test Console”:

Escribimos el texto que viajará en el mensaje y presionamos el botón Execute:

El servicio termina correctamente y podemos ver que nuestra queue ha recibido un mensaje con el texto ingresado.

Creamos un Proxy Service

El Proxy service nos permitirá exponer el servicio para ser invocado vía http. Ingresamos al wizard de configuración eligiendo la opción “Proxy Service” en el combo “Create Resource”. Ponemos un nombre al servicio e indicamos que lo vamos a crear a partir de nuestro wsdl, el cual elegimos mediante el botón Browse:

Marcamos que podrá ser consumido mediante el protocolo http y definimos la url de invocación:

Dejamos todas las opciones por defecto hasta que termina el wizard y activamos los cambios.

Ahora hay que asociar el Proxy a nuestro business service. Para eso editamos el flujo del mensaje:

Y definimos un ruteo:

Click en el link <service> para buscar nuestro business service y que nos quede así:

Guardamos los cambios y probamos nuestro Proxy con el ícono de “Launch Test Console”, como hicimos antes con el business service.

Ejecutado ese request podemos ver que el mensaje completo llegó a la queue correctamente.

Agregamos el JMSType al mensaje

Vamos a editar el routeo entre el proxy y el business service para agregar el JMSType del mensaje que se encola:

Presionamos Add header y seleccionamos en el combo la opción JMSType:

Editamos el link <Expression> con el jmsType deseado, en este caso ‘facturaType’. Activamos los cambios y si probamos de nuevo el Proxy vemos que el mensaje se encola con el type indicado.