Diferencia entre revisiones de «JMS con Spring Roo»

De Dos Ideas.
Saltar a: navegación, buscar
(Alternativa 1: Agregar la lógica en el controller)
 
(No se muestran 16 ediciones intermedias de 2 usuarios)
Línea 1: Línea 1:
 
Con el uso de [[JMS]] podemos hacer asincrónica la ocurrencia de un determinado evento.
 
Con el uso de [[JMS]] podemos hacer asincrónica la ocurrencia de un determinado evento.
  
Entonces, tomamos el [[Ejemplo de proyecto web ABM con Spring Roo]] y hacemos que una vez creado un nuevo pedido de pizza, se envíe un mensaje a la consola del servidor. Esto último de manera asincrónica.
 
  
== Alternativa 1: Modificar el aspecto de la entidad "Pedido"==
+
== Comandos Roo para JMS ==
 +
 
 +
Para crear una cola en memoria:
 +
<code>
 +
jms setup --provider ACTIVEMQ_IN_MEMORY --destinationType QUEUE --destinationName unNombreJndi
 +
</code>
 +
 
 +
Para crear un jmsTemplate que encole mensajes en la queue creada anteriormente:
 +
<code>
 +
field jms template --class com.dosideas.roo.unpackage.UnaClase --fieldName jmsTemplate
 +
</code>
 +
 
 +
Para crear un listener que consuma los mensajes de la queue:
 +
<code>
 +
jms listener class --class com.dosideas.roo.unpackage.UnaClaseListener --destinationName unNombreJndi --destinationType QUEUE
 +
</code>
 +
 
 +
== Integrando el envío de mensajes JMS a una aplicación Roo ==
 +
 
 +
Tomamos el [[Ejemplo de proyecto web ABM con Spring Roo]] y hacemos que una vez creado un nuevo pedido de pizza, se envíe un mensaje a la consola del servidor. Esto último de manera asincrónica.
 +
 
 +
=== Paso 1: Crear una queue ===
 +
 
 +
* Ejecutamos el comando JMS de Spring Roo para crear una cola en memoria:
 +
<code>
 +
jms setup --provider ACTIVEMQ_IN_MEMORY --destinationType QUEUE --destinationName dosIdeasQueue
 +
Created SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml
 +
Managed SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml
 +
Managed ROOT\pom.xml
 +
Managed ROOT\pom.xml
 +
Managed ROOT\pom.xml
 +
Managed ROOT\pom.xml
 +
Managed ROOT\pom.xml
 +
Managed ROOT\pom.xml
 +
</code>
 +
 
 +
* Modificamos la configuración de namespaces de MQ. En el archivo applicationContext-jms.xml sacamos la versión del xsd de activemq, quedando http://activemq.apache.org/schema/core/activemq-core.xsd. Para que no muestre el error desde el IDE ver [[http://www.bigsoft.co.uk/blog/index.php/2009/02/01/invalid-activemq-schema-name-space como modificar las preferencias de Eclipse]]
 +
 
 +
=== Paso 2: Agregar lógica de envío de mensajes ===
 +
==== Alternativa 1: Agregar la lógica en el controller ====
  
 
* Comentamos la anotacion en el aspecto de la entidad:   
 
* Comentamos la anotacion en el aspecto de la entidad:   
 
 
<code>
 
<code>
 
privileged aspect PedidoController_Roo_Controller {
 
privileged aspect PedidoController_Roo_Controller {
 
      
 
      
//@RequestMapping(value = "/pedido", method = RequestMethod.POST)
+
  //@RequestMapping(value = "/pedido", method = RequestMethod.POST)
 
     public String PedidoController.create
 
     public String PedidoController.create
 
</code>
 
</code>
 +
 +
Cada vez que se ejecuta un comando, Spring Roo re-escribe esta anotación en el aspecto, por lo que deberá ser comentada nuevamente. De lo contrario queda anotado en el aspecto y en el controller de la entidad el mismo path y al crear un pedido en runtime, da error.
  
 
* Agregamos un método "crear" en el Controller para crear el pedido y donde vamos a inyectar el uso de mensajeria para mandar el aviso:
 
* Agregamos un método "crear" en el Controller para crear el pedido y donde vamos a inyectar el uso de mensajeria para mandar el aviso:
Línea 27: Línea 66:
 
</code>
 
</code>
  
* Ejecutamos el comando JMS de Spring Roo para crear una cola en memoria:
+
* Ejecutamos el comando de Spring Roo para crear el template en PedidoController:
  
 
<code>
 
<code>
jms setup --provider ACTIVEMQ_IN_MEMORY --destinationType QUEUE --destinationName dosIdeasQueue
+
field jms template --class com.dosideas.roo.oracle.web.PedidoController --fieldName jmsTemplate
Created SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml
+
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController.java
Managed SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml
+
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController.java
Managed ROOT\pom.xml
+
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController_Roo_Controller.aj
Managed ROOT\pom.xml
 
Managed ROOT\pom.xml
 
Managed ROOT\pom.xml
 
Managed ROOT\pom.xml
 
Managed ROOT\pom.xml
 
 
</code>
 
</code>
  
* Modificamos la configuración de la versión de MQ. En el archivo applicationContext-jms.xml configuramos http://activemq.apache.org/schema/core/activemq-core.xsd. Para que no muestre el error desde el IDE ver [[http://www.bigsoft.co.uk/blog/index.php/2009/02/01/invalid-activemq-schema-name-space como modificar las preferencias de Eclipse]]
+
* En el controller, agregamos el uso de la mensajería -sendMessage-:
  
* Ejecutamos el comando de Spring Roo para crear el template:
+
<code>
 +
public class PedidoController {
 +
    @RequestMapping(value = "/pedido", method = RequestMethod.POST)
 +
    public String crear(@Valid Pedido pedido, BindingResult result, ModelMap modelMap) {
 +
    System.out.println("Estoy en PedidoController - crear");
 +
        String resultado = create(pedido, result, modelMap);
 +
        sendMessage("Pedido Enviado:" + pedido);
 +
        return resultado;
 +
    }
 +
 +
    public void sendMessage(Object messageObject) {
 +
        jmsTemplate.convertAndSend(messageObject);
 +
    }
 +
}
 +
</code>
  
 +
==== Alternativa 2: Agregar la lógica en la entidad ====
 +
 +
* Agregamos una capa de negocio para la funcionalidad que agregamos: Creamos una clase JmsQueueSenderBoImpl anotada con @Service y le creamos un atributo template de envío de mensajes con el comando de roo ya mencionado:
 
<code>
 
<code>
field jms template --class com.dosideas.roo.oracle.web.PedidoController --fieldName jmsTemplate
+
field jms template --class com.dosideas.roo.oracle.business.JmsQueueSenderBoImpl  --fieldName jmsTemplate
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController.java
 
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController.java
 
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController_Roo_Controller.aj
 
 
</code>
 
</code>
  
Cada vez que se ejecuta un comando, Spring Roo re-escribe la anotación en el aspecto:
+
La clase queda entonces así:
  
 
<code>
 
<code>
@RequestMapping(value = "/pedido", method = RequestMethod.POST)
+
package com.dosideas.roo.oracle.business;
 +
 
 +
import org.springframework.beans.factory.annotation.Autowired;
 +
import org.springframework.jms.core.JmsTemplate;
 +
import org.springframework.stereotype.Service;
 +
 
 +
@Service
 +
public class JmsQueueSenderBoImpl {
 +
    @Autowired
 +
    private transient JmsTemplate jmsTemplate;
 +
 
 +
    public void sendMessage(Object messageObject) {
 +
        jmsTemplate.convertAndSend(messageObject);
 +
    }
 +
}
 
</code>
 
</code>
  
Entonces, queda anotado en el aspecto y el controller de la entidad y al crear un pedido en runtime, da error.
+
* En la entidad Pedido.java, agregamos el uso de un servicio anotado en la clase de negocio: Usamos la anotación Jpa @PostPersist para indicar que primero debe persistir la entidad y luego realizar el envío del mensaje.
  
* Ejecutamos el comando de Spring Roo para crear el listener:
+
<code> 
 +
    @Autowired
 +
    private transient JmsQueueSenderBoImpl senderBoImpl;
 +
   
 +
    @PostPersist
 +
    public void crear() {
 +
        senderBoImpl.sendMessage("Pedido Enviado:" + this);   
 +
    }
 +
</code>
 +
 
 +
=== Paso 3: Crear un consumidor de los mensajes de la queue ===
 +
* Ejecutamos el comando de Spring Roo para crear una clase listener que consuma los mensajes:
  
 
<code>
 
<code>
 
jms listener class --class com.dosideas.roo.oracle.jms.JmsQueueListener --destinationName dosIdeasQueue --destinationType QUEUE
 
jms listener class --class com.dosideas.roo.oracle.jms.JmsQueueListener --destinationName dosIdeasQueue --destinationType QUEUE
Created SRC_MAIN_JAVA\com\dosideas\roo\oracle\jms
 
Created SRC_MAIN_JAVA\com\dosideas\roo\oracle\jms\JmsQueueListener.java
 
Managed SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml
 
 
</code>
 
</code>
  
== Alternativa 2: Utilizar una anotacion ==
+
* En el onMessage, escribimos el mensaje que recibimos:
 +
<code>
 +
public class JmsQueueListener {
 +
 
 +
    public void onMessage(Object message) {
 +
        System.out.println("Pedido recibido por JMS: " + message);
 +
    }
 +
}
 +
</code>
 +
 
 +
* Ejecutamos la aplicación, creamos un pedido y vemos el siguiente mensaje en consola:
 +
 
 +
<code>
 +
Pedido Enviado:Id: 1, Version: 0, Nombre: aa, Direccion: aa, Importe: 11.0, FechaEntrega: Tue Jul 27 00:00:00 VET 2010, Pizzas: 0
 +
</code>
 +
 
  
 
== Ver tambien ==
 
== Ver tambien ==

Revisión actual del 21:21 28 jul 2010

Con el uso de JMS podemos hacer asincrónica la ocurrencia de un determinado evento.


Comandos Roo para JMS

Para crear una cola en memoria: jms setup --provider ACTIVEMQ_IN_MEMORY --destinationType QUEUE --destinationName unNombreJndi

Para crear un jmsTemplate que encole mensajes en la queue creada anteriormente: field jms template --class com.dosideas.roo.unpackage.UnaClase --fieldName jmsTemplate

Para crear un listener que consuma los mensajes de la queue: jms listener class --class com.dosideas.roo.unpackage.UnaClaseListener --destinationName unNombreJndi --destinationType QUEUE

Integrando el envío de mensajes JMS a una aplicación Roo

Tomamos el Ejemplo de proyecto web ABM con Spring Roo y hacemos que una vez creado un nuevo pedido de pizza, se envíe un mensaje a la consola del servidor. Esto último de manera asincrónica.

Paso 1: Crear una queue

  • Ejecutamos el comando JMS de Spring Roo para crear una cola en memoria:

jms setup --provider ACTIVEMQ_IN_MEMORY --destinationType QUEUE --destinationName dosIdeasQueue Created SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml Managed SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml Managed ROOT\pom.xml Managed ROOT\pom.xml Managed ROOT\pom.xml Managed ROOT\pom.xml Managed ROOT\pom.xml Managed ROOT\pom.xml

Paso 2: Agregar lógica de envío de mensajes

Alternativa 1: Agregar la lógica en el controller

  • Comentamos la anotacion en el aspecto de la entidad:

privileged aspect PedidoController_Roo_Controller {

  //@RequestMapping(value = "/pedido", method = RequestMethod.POST)
   public String PedidoController.create

Cada vez que se ejecuta un comando, Spring Roo re-escribe esta anotación en el aspecto, por lo que deberá ser comentada nuevamente. De lo contrario queda anotado en el aspecto y en el controller de la entidad el mismo path y al crear un pedido en runtime, da error.

  • Agregamos un método "crear" en el Controller para crear el pedido y donde vamos a inyectar el uso de mensajeria para mandar el aviso:

public class PedidoController {

   @RequestMapping(value = "/pedido", method = RequestMethod.POST)
   public String crear(@Valid Pedido pedido, BindingResult result, ModelMap modelMap) {
   	System.out.println("Estoy en PedidoController - crear");
       String resultado = create(pedido, result, modelMap);
       return resultado;
   }	

}

  • Ejecutamos el comando de Spring Roo para crear el template en PedidoController:

field jms template --class com.dosideas.roo.oracle.web.PedidoController --fieldName jmsTemplate Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController.java Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController.java Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController_Roo_Controller.aj

  • En el controller, agregamos el uso de la mensajería -sendMessage-:

public class PedidoController {

   @RequestMapping(value = "/pedido", method = RequestMethod.POST)
   public String crear(@Valid Pedido pedido, BindingResult result, ModelMap modelMap) {
   	System.out.println("Estoy en PedidoController - crear");
       String resultado = create(pedido, result, modelMap);
       sendMessage("Pedido Enviado:" + pedido); 
       return resultado;
   }
   public void sendMessage(Object messageObject) {
       jmsTemplate.convertAndSend(messageObject);
   }

}

Alternativa 2: Agregar la lógica en la entidad

  • Agregamos una capa de negocio para la funcionalidad que agregamos: Creamos una clase JmsQueueSenderBoImpl anotada con @Service y le creamos un atributo template de envío de mensajes con el comando de roo ya mencionado:

field jms template --class com.dosideas.roo.oracle.business.JmsQueueSenderBoImpl --fieldName jmsTemplate

La clase queda entonces así:

package com.dosideas.roo.oracle.business;

import org.springframework.beans.factory.annotation.Autowired; import org.springframework.jms.core.JmsTemplate; import org.springframework.stereotype.Service;

@Service public class JmsQueueSenderBoImpl {

   @Autowired
   private transient JmsTemplate jmsTemplate;
   public void sendMessage(Object messageObject) {
       jmsTemplate.convertAndSend(messageObject);
   }

}

  • En la entidad Pedido.java, agregamos el uso de un servicio anotado en la clase de negocio: Usamos la anotación Jpa @PostPersist para indicar que primero debe persistir la entidad y luego realizar el envío del mensaje.

   @Autowired
   private transient JmsQueueSenderBoImpl senderBoImpl;
   
   @PostPersist
   public void crear() {
       senderBoImpl.sendMessage("Pedido Enviado:" + this);     
   }

Paso 3: Crear un consumidor de los mensajes de la queue

  • Ejecutamos el comando de Spring Roo para crear una clase listener que consuma los mensajes:

jms listener class --class com.dosideas.roo.oracle.jms.JmsQueueListener --destinationName dosIdeasQueue --destinationType QUEUE

  • En el onMessage, escribimos el mensaje que recibimos:

public class JmsQueueListener {

   public void onMessage(Object message) {
       System.out.println("Pedido recibido por JMS: " + message);
   }

}

  • Ejecutamos la aplicación, creamos un pedido y vemos el siguiente mensaje en consola:

Pedido Enviado:Id: 1, Version: 0, Nombre: aa, Direccion: aa, Importe: 11.0, FechaEntrega: Tue Jul 27 00:00:00 VET 2010, Pizzas: 0


Ver tambien