Diferencia entre revisiones de «JMS con Spring Roo»
(→Alternativa 2: Utilizar una anotacion) |
|||
Línea 97: | Línea 97: | ||
} | } | ||
</code> | </code> | ||
− | |||
* Ejecutamos la aplicación, creamos un pedido y vemos el siguiente mensaje en consola: | * Ejecutamos la aplicación, creamos un pedido y vemos el siguiente mensaje en consola: | ||
Línea 120: | Línea 119: | ||
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]] | * 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]] | ||
− | |||
* Ejecutamos el comando de Spring Roo para crear el template: | * Ejecutamos el comando de Spring Roo para crear el template: | ||
Línea 133: | Línea 130: | ||
Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController_Roo_Controller.aj | Managed SRC_MAIN_JAVA\com\dosideas\roo\oracle\web\PedidoController_Roo_Controller.aj | ||
</code> | </code> | ||
− | |||
* Ejecutamos el comando de Spring Roo para crear el listener: | * Ejecutamos el comando de Spring Roo para crear el listener: | ||
Línea 143: | Línea 139: | ||
Managed SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml | Managed SRC_MAIN_RESOURCES\META-INF\spring\applicationContext-jms.xml | ||
</code> | </code> | ||
− | |||
* En el onMessage, escribimos el mensaje que queremos enviar: | * En el onMessage, escribimos el mensaje que queremos enviar: | ||
Línea 155: | Línea 150: | ||
} | } | ||
</code> | </code> | ||
− | |||
* Agregamos una capa de negocio para la funcionalidad que agregamos: | * Agregamos una capa de negocio para la funcionalidad que agregamos: | ||
Línea 176: | Línea 170: | ||
} | } | ||
</code> | </code> | ||
− | |||
* En la entidad Pedido.java, agregamos el uso de un servicio anotado en la clase de negocio: | * En la entidad Pedido.java, agregamos el uso de un servicio anotado en la clase de negocio: | ||
Línea 189: | Línea 182: | ||
} | } | ||
</code> | </code> | ||
− | |||
* Ejecutamos la aplicación, creamos un pedido y vemos el siguiente mensaje en consola: | * Ejecutamos la aplicación, creamos un pedido y vemos el siguiente mensaje en consola: |
Revisión del 19:46 28 jul 2010
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
Alternativa 2: Utilizar una anotacion
- 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
- 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); }
}
- Agregamos una capa de negocio para la funcionalidad que agregamos:
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:
@Autowired private transient JmsQueueSenderBoImpl senderBoImpl; @PostPersist public void crear() { senderBoImpl.sendMessage("Pedido Enviado:" + this); }
- 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