demo/org.argeo.slc.demo.manager/src/test/java/org/argeo/slc/demo/manager/JmsTesting.java

   1 package org.argeo.slc.demo.manager;
   2
   3 import javax.jms.ConnectionFactory;
   4 import javax.jms.JMSException;
   5 import javax.jms.Message;
   6 import javax.jms.Session;
   7 import javax.jms.TextMessage;
   8
   9 import org.apache.commons.logging.Log;
  10 import org.apache.commons.logging.LogFactory;
  11 import org.apache.xbean.spring.context.ClassPathXmlApplicationContext;
  12 import org.springframework.beans.BeansException;
  13 import org.springframework.jms.JmsException;
  14 import org.springframework.jms.core.JmsTemplate;
  15 import org.springframework.jms.core.MessageCreator;
  16
  17 public class JmsTesting {
  18         private final static Log log = LogFactory.getLog(JmsTesting.class);
  19
  20         /**
  21          * @param args
  22          */
  23         public static void main(String[] args) {
  24                 ClassPathXmlApplicationContext applicationContext = new ClassPathXmlApplicationContext(
  25                                 "org/argeo/slc/activemq/spring.xml");
  26                 try {
  27
  28                         ConnectionFactory connectionFactory = (ConnectionFactory) applicationContext
  29                                         .getBean("slcDefault.jms.connectionFactory");
  30                         JmsTemplate jmsTemplate = new JmsTemplate(connectionFactory);
  31
  32                         jmsTemplate.send("modulesManager.request", new MessageCreator() {
  33
  34                                 public Message createMessage(Session session)
  35                                                 throws JMSException {
  36                                         TextMessage message = session.createTextMessage();
  37                                         message.setStringProperty("action",
  38                                                         "getExecutionModuleDescriptor");
  39                                         message.setStringProperty("name",
  40                                                         "org.argeo.slc.demo.basic");
  41                                         message.setStringProperty("version", "LATEST");
  42                                         return message;
  43                                 }
  44                         });
  45
  46                         TextMessage message = (TextMessage) jmsTemplate
  47                                         .receive("modulesManager.response");
  48                         log.info("Received message: " + message.getText() + "\n");
  49
  50                 } catch (Exception e) {
  51                         e.printStackTrace();
  52                 } finally {
  53                         applicationContext.close();
  54                 }
  55         }
  56
  57 }