diff --git a/spring-jms/src/com/baeldung/spring/jms/SampleListener.java b/spring-jms/src/com/baeldung/spring/jms/SampleListener.java
index 466cac44a0..8c28ab3e35 100644
--- a/spring-jms/src/com/baeldung/spring/jms/SampleListener.java
+++ b/spring-jms/src/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");
         }
     }
-}
\ No newline at end of file
+
+    public Employee receiveMessage() throws JMSException {
+        Map map = (Map) getJmsTemplate().receiveAndConvert();
+        Employee employee = new Employee((String) map.get("name"), (Integer) map.get("age"));
+        return employee;
+    }
+}