Merge branch 'kirangonella-master'

spring-jms/src/main/java/com/baeldung/spring/jms/Employee.java

@@ -18,6 +18,6 @@ public class Employee {
     }
 
     public String toString() {
-        return "Person: name(" + name + "), age(" + age + ")";
+        return "Employee: name(" + name + "), age(" + age + ")";
     }
 }

spring-jms/src/main/java/com/baeldung/spring/jms/SampleJMSExample.java

@@ -1,16 +0,0 @@
-package com.baeldung.spring.jms;
-
-import org.apache.activemq.broker.BrokerFactory;
-import org.apache.activemq.broker.BrokerService;
-import org.springframework.context.support.ClassPathXmlApplicationContext;
-
-import java.net.URI;
-
-public class SampleJMSExample {
-    public static void main(String[] args) throws Exception {
-        BrokerService broker = BrokerFactory.createBroker(new URI("broker:(tcp://localhost:61616)"));
-        broker.start();
-        ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("applicationContext.xml");
-
-    }
-}

spring-jms/src/main/java/com/baeldung/spring/jms/SampleJmsMessageSender.java

@@ -1,17 +1,23 @@
 package com.baeldung.spring.jms;
 
+import java.util.HashMap;
+import java.util.Map;
+
+import javax.jms.JMSException;
+import javax.jms.Message;
+import javax.jms.Queue;
+import javax.jms.Session;
+
 import org.springframework.jms.core.JmsTemplate;
 import org.springframework.jms.core.MessageCreator;
 
-import javax.jms.*;
-
 public class SampleJmsMessageSender {
 
     private JmsTemplate jmsTemplate;
     private Queue queue;
 
-    public void createJmsTemplate(ConnectionFactory cf) {
+    public void setJmsTemplate(JmsTemplate jmsTemplate) {
-        this.jmsTemplate = new JmsTemplate(cf);
+        this.jmsTemplate = jmsTemplate;
     }
 
     public void setQueue(Queue queue) {
@@ -25,4 +31,12 @@ public class SampleJmsMessageSender {
             }
         });
     }
+
+    public void sendMessage(final Employee employee) {
+        System.out.println("Jms Message Sender : " + employee);
+        Map<String, Object> map = new HashMap<String, Object>();
+        map.put("name", employee.getName());
+        map.put("age", employee.getAge());
+        this.jmsTemplate.convertAndSend(map);
+    }
 }

spring-jms/src/main/java/com/baeldung/spring/jms/SampleListener.java

@@ -1,18 +1,26 @@
 package com.baeldung.spring.jms;
 
+import java.util.Map;
+
 import javax.jms.JMSException;
 import javax.jms.Message;
 import javax.jms.MessageListener;
 import javax.jms.TextMessage;
 
+import org.springframework.jms.core.JmsTemplate;
+
 public class SampleListener implements MessageListener {
 
-    private String textMessage;
+    public JmsTemplate getJmsTemplate() {
+        return getJmsTemplate();
+    }
 
     public void onMessage(Message message) {
         if (message instanceof TextMessage) {
             try {
-                textMessage = ((TextMessage) message).getText();
+
+                String msg = ((TextMessage) message).getText();
+                System.out.println("Message has been consumed : " + msg);
             } catch (JMSException ex) {
                 throw new RuntimeException(ex);
             }
@@ -20,4 +28,10 @@ public class SampleListener implements MessageListener {
             throw new IllegalArgumentException("Message Error");
         }
     }
+
+    public Employee receiveMessage() throws JMSException {
+        Map map = (Map) getJmsTemplate().receiveAndConvert();
+        Employee employee = new Employee((String) map.get("name"), (Integer) map.get("age"));
+        return employee;
+    }
 }

spring-jms/src/main/java/com/baeldung/spring/jms/SampleMessageConverter.java

@@ -1,26 +1,27 @@
 package com.baeldung.spring.jms;
 
-import org.springframework.jms.support.converter.MessageConversionException;
-import org.springframework.jms.support.converter.MessageConverter;
-
 import javax.jms.JMSException;
 import javax.jms.MapMessage;
 import javax.jms.Message;
 import javax.jms.Session;
 
+import org.springframework.jms.support.converter.MessageConversionException;
+import org.springframework.jms.support.converter.MessageConverter;
+
 public class SampleMessageConverter implements MessageConverter {
 
     public Message toMessage(Object object, Session session) throws JMSException, MessageConversionException {
-        Employee person = (Employee) object;
+        Employee employee = (Employee) object;
         MapMessage message = session.createMapMessage();
-        message.setString("name", person.getName());
+        message.setString("name", employee.getName());
-        message.setInt("age", person.getAge());
+        message.setInt("age", employee.getAge());
         return message;
     }
 
     public Object fromMessage(Message message) throws JMSException, MessageConversionException {
         MapMessage mapMessage = (MapMessage) message;
-        return new Employee(mapMessage.getString("name"), mapMessage.getInt("age"));
+        Employee employee = new Employee(mapMessage.getString("name"), mapMessage.getInt("age"));
+        return employee;
     }
 
 }

spring-jms/src/main/resources/EmbeddedActiveMQ.xml

@@ -0,0 +1,18 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<beans xmlns="http://www.springframework.org/schema/beans"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p"
+    xmlns:aop="http://www.springframework.org/schema/aop" xmlns:context="http://www.springframework.org/schema/context"
+    xmlns:jee="http://www.springframework.org/schema/jee" xmlns:tx="http://www.springframework.org/schema/tx"
+    xmlns:util="http://www.springframework.org/schema/util" xmlns:task="http://www.springframework.org/schema/task"
+    xmlns:amq="http://activemq.apache.org/schema/core"
+    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://activemq.apache.org/schema/core
+                        http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd http://www.springframework.org/schema/util http://www.springframework.org/schema/util/spring-util.xsd">
+ 
+    <!-- Embedded ActiveMQ Broker -->
+    <amq:broker id="broker" useJmx="false" persistent="false">
+        <amq:transportConnectors>
+            <amq:transportConnector uri="tcp://localhost:61616" />
+        </amq:transportConnectors>
+    </amq:broker>
+ 
+</beans>

spring-jms/src/main/resources/applicationContext.xml

@@ -3,16 +3,27 @@
 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">
 
-	<bean id="messageDestination" class="org.apache.activemq.command.ActiveMQQueue">
+	 <bean id="amqConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
-		<constructor-arg value="messageQueue1" />
+        <constructor-arg index="0" value="tcp://localhost:61616" />
-	</bean>
-	<bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
-		<property name="connectionFactory" ref="connectionFactory" />
-		<property name="receiveTimeout" value="10000" />
     </bean>
  
+    <!-- ConnectionFactory Definition -->
+    <bean id="connectionFactory"
+        class="org.springframework.jms.connection.CachingConnectionFactory">
+        <constructor-arg ref="amqConnectionFactory" />
+    </bean>
+	
+	<bean id="destinationQueue" class="org.apache.activemq.command.ActiveMQQueue">
+        <constructor-arg index="0" value="IN_QUEUE" />
+    </bean>
+ 
+    <!-- JmsTemplate Definition -->
+    <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
+        <property name="connectionFactory" ref="connectionFactory" />
+        <property name="defaultDestination" ref="destinationQueue" />
+    </bean>
 	<bean id="SampleJmsMessageSender" class="com.baeldung.spring.jms.SampleJmsMessageSender">
-		<property name="destination" ref="messageDestination" />
+		<property name="queue" ref="destinationQueue" />
 		<property name="jmsTemplate" ref="jmsTemplate" />
 	</bean>
 
@@ -23,8 +34,7 @@
 	<bean id="jmsContainer"
 		class="org.springframework.jms.listener.DefaultMessageListenerContainer">
 		<property name="connectionFactory" ref="connectionFactory" />
-		<property name="destination" ref="messageDestination" />
+		<property name="destinationName" value="IN_QUEUE" />
 		<property name="messageListener" ref="messageListener" />
-		<property name="jmsTemplate" ref="jmsTemplate" />
 	</bean>
 </beans>

spring-jms/src/test/com/baeldung/spring/jms/DefaultTextMessageSenderTest.java

@@ -0,0 +1,25 @@
+package com.baeldung.spring.jms;
+
+import com.baeldung.spring.jms.SampleJmsMessageSender;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class DefaultTextMessageSenderTest {
+
+    private static SampleJmsMessageSender messageProducer;
+
+    @SuppressWarnings("resource")
+    @BeforeClass
+    public static void setUp() {
+        ApplicationContext applicationContext = new ClassPathXmlApplicationContext(new String[] { "classpath:EmbeddedActiveMQ.xml", "classpath:applicationContext.xml" });
+        messageProducer = (SampleJmsMessageSender) applicationContext.getBean("SampleJmsMessageSender");
+    }
+
+    @Test
+    public void testSimpleSend() {
+        messageProducer.simpleSend();
+    }
+
+}

spring-jms/src/test/com/baeldung/spring/jms/MapMessageConvertAndSendTest.java

@@ -0,0 +1,26 @@
+package com.baeldung.spring.jms;
+
+import com.baeldung.spring.jms.Employee;
+import com.baeldung.spring.jms.SampleJmsMessageSender;
+import org.junit.BeforeClass;
+import org.junit.Test;
+import org.springframework.context.ApplicationContext;
+import org.springframework.context.support.ClassPathXmlApplicationContext;
+
+public class MapMessageConvertAndSendTest {
+
+    private static SampleJmsMessageSender messageProducer;
+
+    @SuppressWarnings("resource")
+    @BeforeClass
+    public static void setUp() {
+        ApplicationContext applicationContext = new ClassPathXmlApplicationContext(new String[] { "classpath:EmbeddedActiveMQ.xml", "classpath:applicationContext.xml" });
+        messageProducer = (SampleJmsMessageSender) applicationContext.getBean("SampleJmsMessageSender");
+    }
+
+    @Test
+    public void testSendMessage() {
+        messageProducer.sendMessage(new Employee("JavaDeveloper2", 22));
+    }
+
+}