JMS con Spring Roo
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"
- Comentamos la anotacion en el aspecto de la entidad:
privileged aspect PedidoController_Roo_Controller {
//@RequestMapping(value = "/pedido", method = RequestMethod.POST)
public String PedidoController.create
- 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 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
- 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 [como modificar las preferencias de Eclipse]
- Ejecutamos el comando de Spring Roo para crear el template:
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
Cada vez que se ejecuta un comando, Spring Roo re-escribe la anotación en el aspecto:
@RequestMapping(value = "/pedido", method = RequestMethod.POST)
Entonces, queda anotado en el aspecto y el controller de la entidad y al crear un pedido en runtime, da error.
- Ejecutamos el comando de Spring Roo para crear el listener:
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
- En el onMessage, escribimos el mensaje que queremos enviar:
public class JmsQueueListener {
public void onMessage(Object message) {
System.out.println("Pedido recibido por JMS: " + message);
}
}
- 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);
}
}
- 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
