{"id":27968,"date":"2015-10-16T15:00:39","date_gmt":"2015-10-16T12:00:39","guid":{"rendered":"http:\/\/examples.javacodegeeks.com\/?p=27968"},"modified":"2015-10-15T22:11:42","modified_gmt":"2015-10-15T19:11:42","slug":"spring-jms-example","status":"publish","type":"post","link":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/","title":{"rendered":"Spring JMS Example"},"content":{"rendered":"

Java Messaging Service (JMS) is a standard messaging API used to send and receive messages.<\/p>\n

Spring simplifies the use of JMS API by providing another layer around the JMS layer.<\/p>\n

This layer provides convenience methods for sending and receiving messages, as well as manages the creation and release of resources like the connection object.<\/p>\n

The JmsTemplate<\/code> class is the main class which we will be using often to work with the JMS API.<\/p>\n

1. Dependencies<\/h2>\n

In order to send and receive JMS messages to and from a JMS message broker, we need to include the message service library. In this example we are using activeMq so our pom.xml will have dependencies related to spring as well as activeMq.<\/p>\n

pom.xml:<\/em><\/span><\/p>\n

<project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n\txsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\">\r\n\t<modelVersion>4.0.0<\/modelVersion>\r\n\t<groupId>com.javacodegeeks.camel<\/groupId>\r\n\t<artifactId>springQuartzScheduler<\/artifactId>\r\n\t<version>0.0.1-SNAPSHOT<\/version>\r\n\t<dependencies>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.springframework<\/groupId>\r\n\t\t\t<artifactId>spring-core<\/artifactId>\r\n\t\t\t<version>4.1.5.RELEASE<\/version>\r\n\t\t<\/dependency>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.springframework<\/groupId>\r\n\t\t\t<artifactId>spring-context<\/artifactId>\r\n\t\t\t<version>4.1.5.RELEASE<\/version>\r\n\t\t<\/dependency>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.springframework<\/groupId>\r\n\t\t\t<artifactId>spring-jms<\/artifactId>\r\n\t\t\t<version>4.1.5.RELEASE<\/version>\r\n\t\t<\/dependency>\r\n\t\t<dependency>\r\n\t\t\t<groupId>org.apache.activemq<\/groupId>\r\n\t\t\t<artifactId>activemq-all<\/artifactId>\r\n\t\t\t<version>5.12.0<\/version>\r\n\t\t<\/dependency>\r\n\t<\/dependencies>\r\n\t\r\n<\/project>\r\n<\/pre>\n
2. Spring JmsTemplate Example<\/h2>\n
Spring provides JMS integration using JmsTemplate<\/code> class. It helps eliminating the verbose and repetitive JMS code. JmsTemplate<\/code> also takes care of creating a connection, obtaining a session, and the actual sending and receiving of messages. This helps the developer to just focus on the construction of message. If any JMS exception is thrown, it will be rethrown as unchecked exception as a subclass of JmsException<\/code>.<\/p>\n
Let’s start with the producer.<\/p>\n
In the below class, notice the sendMessage() method. It delegates the call to JmsTemplate.send()<\/code>. The call depends on the message destination, as well as a MessageCreator object, which creates the JMS message you are going to send. The MessageCreator object is usually implemented as an anonymous inner class. Here we are sending a text message.<\/p>\n
SpringJmsProducer:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport javax.jms.Destination;\r\nimport javax.jms.JMSException;\r\nimport javax.jms.Message;\r\nimport javax.jms.Session;\r\n\r\nimport org.springframework.jms.core.JmsTemplate;\r\nimport org.springframework.jms.core.MessageCreator;\r\n\r\npublic class SpringJmsProducer {\r\n\tprivate JmsTemplate jmsTemplate;\r\n\tprivate Destination destination;\r\n\t\r\n\tpublic JmsTemplate getJmsTemplate() {\r\n\t\treturn jmsTemplate;\r\n\t}\r\n\r\n\tpublic void setJmsTemplate(JmsTemplate jmsTemplate) {\r\n\t\tthis.jmsTemplate = jmsTemplate;\r\n\t}\r\n\t\r\n\tpublic Destination getDestination() {\r\n\t\treturn destination;\r\n\t}\r\n\r\n\tpublic void setDestination(Destination destination) {\r\n\t\tthis.destination = destination;\r\n\t}\r\n\r\n\tpublic void sendMessage(final String msg) {\r\n\t\tSystem.out.println(\"Producer sends \" + msg);\r\n\t\tjmsTemplate.send(destination, new MessageCreator() {\r\n\t\t\tpublic Message createMessage(Session session) throws JMSException {\r\n\t\t\t\treturn session.createTextMessage(msg);\r\n\t\t\t}});\t\t\r\n\t}\r\n}\r\n<\/pre>\n
In the consumer, we will receive the JMS message again with the help of the JMS template. In receiveMessage()<\/code>, the call is delegated to JdbcTemplate.receive()<\/code> method by providing a message destination. This method returns a JMS message of type javax.jms.Message<\/code>. Since we know the message is a TextMessage<\/code> we return the actual payload by calling textMessage.getText()<\/code>.<\/p>\n
SpringJmsConsumer:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport javax.jms.Destination;\r\nimport javax.jms.JMSException;\r\nimport javax.jms.TextMessage;\r\n\r\nimport org.springframework.jms.core.JmsTemplate;\r\n\r\npublic class SpringJmsConsumer {\r\n\tprivate JmsTemplate jmsTemplate;\r\n\tprivate Destination destination;\r\n\t\r\n\tpublic JmsTemplate getJmsTemplate() {\r\n\t\treturn jmsTemplate;\r\n\t}\r\n\r\n\tpublic void setJmsTemplate(JmsTemplate jmsTemplate) {\r\n\t\tthis.jmsTemplate = jmsTemplate;\r\n\t}\r\n\t\r\n\tpublic Destination getDestination() {\r\n\t\treturn destination;\r\n\t}\r\n\r\n\tpublic void setDestination(Destination destination) {\r\n\t\tthis.destination = destination;\r\n\t}\r\n\r\n\tpublic String receiveMessage() throws JMSException {\r\n\t\tTextMessage textMessage = (TextMessage) jmsTemplate.receive(destination);\t\t\r\n\t\treturn textMessage.getText();\r\n\t}\r\n}\r\n<\/pre>\n
3. Configuring JmsTemplate<\/h2>\n
In this section, we will configure a connection factory which we will use to create connection. The connection factory will help us connect to the message broker. Since we\u2019re using ActiveMQ as our message broker, we\u2019ll have to configure the JMS connection factory so that it knows how to connect to ActiveMQ. ActiveMQConnectionFactory<\/code> is the JMS connection factory that comes with ActiveMQ.<\/p>\n
The brokerURL property tells the connection factory where the message broker is located. The URL we are using is tcp:\/\/localhost:61616<\/code>.<\/p>\n
Next, we need to configure a destination. The destination can be either a queue or a topic, depending on the needs of the application.<\/p>\n
Once we have configured, a connection factory and destination, we will configure the JmsTemplate<\/code> bean. Since both our producer and consumer both are dependent on JmsTemplate, we need to inject the jmsTemplate<\/code> bean in their definitions.<\/p>\n
applicationContext.xml:<\/em><\/span><\/p>\n
<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<beans xmlns=\"http:\/\/www.springframework.org\/schema\/beans\"\r\n\txmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n\txsi:schemaLocation=\"http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd\">\r\n\r\n\t<bean id=\"connectionFactory\" class=\"org.apache.activemq.ActiveMQConnectionFactory\">\r\n\t\t<property name=\"brokerURL\" value=\"tcp:\/\/localhost:61616\" \/>\r\n\t<\/bean>\r\n\t<bean id=\"messageDestination\" class=\"org.apache.activemq.command.ActiveMQQueue\">\r\n\t\t<constructor-arg value=\"messageQueue1\" \/>\r\n\t<\/bean>\r\n\t<bean id=\"jmsTemplate\" class=\"org.springframework.jms.core.JmsTemplate\">\r\n\t\t<property name=\"connectionFactory\" ref=\"connectionFactory\" \/>\r\n\t\t<property name=\"receiveTimeout\" value=\"10000\" \/>\r\n\t<\/bean>\r\n\r\n\t<bean id=\"springJmsProducer\" class=\"com.javacodegeeks.spring.jms.SpringJmsProducer\">\r\n\t\t<property name=\"destination\" ref=\"messageDestination\" \/>\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplate\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsConsumer\" class=\"com.javacodegeeks.spring.jms.SpringJmsConsumer\">\r\n\t\t<property name=\"destination\" ref=\"messageDestination\" \/>\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplate\" \/>\r\n\t<\/bean>\r\n<\/beans>\r\n<\/pre>\n
Let’s test the JMS Example.<\/p>\n
In order for the producer and consumer to connect to the broker, we must have the broker started.<\/p>\n
BrokerService broker = BrokerFactory.createBroker(new URI(\r\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\r\nbroker.start();\r\n<\/pre>\n
Next, we load the spring application context. Once we have the context, we get the producer bean and call springJmsProducer.sendMessage(\"Hi\")<\/code>. This will send the message to the configured destination. In order to receive the message from the destination, we get the consumer bean and call springJmsConsumer.receiveMessage()<\/code>.<\/p>\n
SpringJmsExample:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport java.net.URI;\r\nimport java.net.URISyntaxException;\r\n\r\nimport org.apache.activemq.broker.BrokerFactory;\r\nimport org.apache.activemq.broker.BrokerService;\r\nimport org.springframework.context.support.ClassPathXmlApplicationContext;\r\n\r\npublic class SpringJmsExample {\r\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\r\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\r\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\r\n\t\tbroker.start();\r\n\t\tClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(\r\n\t\t\t\t\"applicationContext.xml\");\r\n\r\n\t\ttry {\r\n\t\t\tSpringJmsProducer springJmsProducer = (SpringJmsProducer) context\r\n\t\t\t\t\t.getBean(\"springJmsProducer\");\r\n\t\t\tspringJmsProducer.sendMessage(\"Hi\");\r\n\r\n\t\t\tSpringJmsConsumer springJmsConsumer = (SpringJmsConsumer) context\r\n\t\t\t\t\t.getBean(\"springJmsConsumer\");\r\n\t\t\tSystem.out.println(\"Consumer receives \" + springJmsConsumer.receiveMessage());\r\n\t\t} finally {\r\n\t\t\tbroker.stop();\r\n\t\t\tcontext.close();\r\n\t\t}\r\n\t}\r\n}\r\n<\/pre>\n
Output:<\/em><\/span>
 
<\/div> <\/div><\/p>\n
 INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\r\n INFO | PListStore:[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\tmp_storage] started\r\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\KahaDB]\r\n INFO | KahaDB is version 6\r\n INFO | Recovering from the journal @1:1580\r\n INFO | Recovery replayed 1 operations from the journal in 0.01 seconds.\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56935-1444920918425-0:1) is starting\r\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\r\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56935-1444920918425-0:1) started\r\n INFO | For help or more information please see: http:\/\/activemq.apache.org\r\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\KahaDB only has 56897 mb of usable space - resetting to maximum available disk space: 56897 mb\r\nProducer sends Hi\r\nConsumer receives Hi\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56935-1444920918425-0:1) is shutting down\r\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\r\n INFO | PListStore:[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\tmp_storage] stopped\r\n INFO | Stopping async queue tasks\r\n INFO | Stopping async topic tasks\r\n INFO | Stopped KahaDB\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56935-1444920918425-0:1) uptime 1.433 seconds\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56935-1444920918425-0:1) is shutdown\r\n<\/pre>\n
4. Spring JmsGatewaySupport Example<\/h2>\n
In this example, our producer and consumer beans will extend JmsGatewaySupport<\/code> to access the JMS template. We will inject the JmsTemplate bean as usual to our producer and consumer beans. With this change, we can get rid of the private field jmsTemplate and its setter method from both the producer and consumer classes.<\/p>\n
SpringJmsGatewayProducer:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport javax.jms.JMSException;\r\nimport javax.jms.Message;\r\nimport javax.jms.Session;\r\n\r\nimport org.springframework.jms.core.MessageCreator;\r\nimport org.springframework.jms.core.support.JmsGatewaySupport;\r\n\r\npublic class SpringJmsGatewayProducer extends JmsGatewaySupport {\r\n\tpublic void sendMessage(final String msg) {\r\n\t\tSystem.out.println(\"Producer sends \" + msg);\r\n\t\tgetJmsTemplate().send(new MessageCreator() {\r\n\t\t\tpublic Message createMessage(Session session) throws JMSException {\r\n\t\t\t\treturn session.createTextMessage(msg);\r\n\t\t\t}});\t\t\r\n\t}\r\n}\r\n<\/pre>\n
SpringJmsGatewayConsumer:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport javax.jms.JMSException;\r\nimport javax.jms.TextMessage;\r\n\r\nimport org.springframework.jms.core.support.JmsGatewaySupport;\r\n\r\npublic class SpringJmsGatewayConsumer extends JmsGatewaySupport {\r\n\tpublic String receiveMessage() throws JMSException {\r\n\t\tTextMessage textMessage = (TextMessage) getJmsTemplate().receive();\t\t\r\n\t\treturn textMessage.getText();\t\t\r\n\t}\r\n}\r\n<\/pre>\n
In jmsTemplateWithDefaultDestination<\/code>, we have specified a default message destination so now we don’t have inject the destination to our producer and consumer beans.<\/p>\n
applicationContext.xml:<\/em><\/span><\/p>\n
<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<beans xmlns=\"http:\/\/www.springframework.org\/schema\/beans\"\r\n\txmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n\txsi:schemaLocation=\"http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd\">\r\n\r\n\t<bean id=\"connectionFactory\" class=\"org.apache.activemq.ActiveMQConnectionFactory\">\r\n\t\t<property name=\"brokerURL\" value=\"tcp:\/\/localhost:61616\" \/>\r\n\t<\/bean>\r\n\t<bean id=\"messageDestination\" class=\"org.apache.activemq.command.ActiveMQQueue\">\r\n\t\t<constructor-arg value=\"messageQueue1\" \/>\r\n\t<\/bean>\r\n\t<bean id=\"jmsTemplate\" class=\"org.springframework.jms.core.JmsTemplate\">\r\n\t\t<property name=\"connectionFactory\" ref=\"connectionFactory\" \/>\r\n\t\t<property name=\"receiveTimeout\" value=\"10000\" \/>\r\n\t<\/bean>\r\n\r\n\t<bean id=\"springJmsProducer\" class=\"com.javacodegeeks.spring.jms.SpringJmsProducer\">\r\n\t\t<property name=\"destination\" ref=\"messageDestination\" \/>\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplate\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsConsumer\" class=\"com.javacodegeeks.spring.jms.SpringJmsConsumer\">\r\n\t\t<property name=\"destination\" ref=\"messageDestination\" \/>\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplate\" \/>\r\n\t<\/bean>\r\n\t\r\n        <bean id=\"jmsTemplateWithDefaultDestination\" class=\"org.springframework.jms.core.JmsTemplate\">\r\n\t\t<property name=\"connectionFactory\" ref=\"connectionFactory\" \/>\r\n\t\t<property name=\"receiveTimeout\" value=\"10000\" \/>\r\n\t\t<property name=\"defaultDestinationName\" value=\"messageQueue2\" \/>\r\n\t<\/bean>\r\n\t\r\n        <bean id=\"springJmsGatewayProducer\" class=\"com.javacodegeeks.spring.jms.SpringJmsGatewayProducer\">\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplateWithDefaultDestination\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsGatewayConsumer\" class=\"com.javacodegeeks.spring.jms.SpringJmsGatewayConsumer\">\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplateWithDefaultDestination\" \/>\r\n\t<\/bean>\r\n<\/beans>\r\n<\/pre>\n
Let’s retest the example now with enhanced producer and consumer beans.<\/p>\n
SpringJmsGatewaySupportExample:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport java.net.URI;\r\nimport java.net.URISyntaxException;\r\n\r\nimport org.apache.activemq.broker.BrokerFactory;\r\nimport org.apache.activemq.broker.BrokerService;\r\nimport org.springframework.context.support.ClassPathXmlApplicationContext;\r\n\r\npublic class SpringJmsGatewaySupportExample {\r\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\r\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\r\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\r\n\t\tbroker.start();\r\n\t\tClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(\r\n\t\t\t\t\"applicationContext.xml\");\r\n\r\n\t\ttry {\r\n\t\t\tSpringJmsGatewayProducer springJmsProducer = (SpringJmsGatewayProducer) context\r\n\t\t\t\t\t.getBean(\"springJmsGatewayProducer\");\r\n\t\t\tspringJmsProducer.sendMessage(\"Hi\");\r\n\r\n\t\t\tSpringJmsGatewayConsumer springJmsConsumer = (SpringJmsGatewayConsumer) context\r\n\t\t\t\t\t.getBean(\"springJmsGatewayConsumer\");\r\n\t\t\tSystem.out.println(\"Consumer receives \" + springJmsConsumer.receiveMessage());\r\n\t\t} finally {\r\n\t\t\tbroker.stop();\r\n\t\t\tcontext.close();\r\n\t\t}\r\n\t}\r\n}\r\n<\/pre>\n
Output:<\/em><\/span><\/p>\n
 INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\r\n INFO | PListStore:[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\tmp_storage] started\r\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\KahaDB]\r\n INFO | KahaDB is version 6\r\n INFO | Recovering from the journal @1:6816\r\n INFO | Recovery replayed 1 operations from the journal in 0.012 seconds.\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-58078-1444922028793-0:1) is starting\r\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\r\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-58078-1444922028793-0:1) started\r\n INFO | For help or more information please see: http:\/\/activemq.apache.org\r\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\KahaDB only has 56898 mb of usable space - resetting to maximum available disk space: 56898 mb\r\nProducer sends Hi\r\nConsumer receives Hi\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-58078-1444922028793-0:1) is shutting down\r\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\r\n INFO | PListStore:[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\tmp_storage] stopped\r\n INFO | Stopping async queue tasks\r\n INFO | Stopping async topic tasks\r\n INFO | Stopped KahaDB\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-58078-1444922028793-0:1) uptime 1.409 seconds\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-58078-1444922028793-0:1) is shutdown\r\n<\/pre>\n
5. Message Converter<\/h2>\n
In this example, we will send\/receive a custom message Person<\/code> bean. We want spring to transform the person object to the Message<\/code> and convert the received Message<\/code> object back to Person<\/code> bean. Spring provides an implementation of SimpleMessageConvertor to handle the translation of a JMS message received to a business object and the translation of a business object to a JMS message.<\/p>\n
Let’s now implement our own MessageConverter<\/code> to handle the raw JMS messages by yourself. Spring\u2019s JMS template can help you convert JMS messages to and from Java objects using a message converter which we will configure in our spring application context. In order to send and receive a map message, we will use the convertAndSend()<\/code> and receiveAndConvert()<\/code> methods, and the map will be converted to\/from MapMessage.<\/p>\n
Here is the person bean.<\/p>\n
Person:<\/span><\/em><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\npublic class Person {\r\n\tprivate String name;\r\n\tprivate Integer age;\r\n\tpublic Person(String name, Integer age) {\r\n\t\tthis.name = name;\r\n\t\tthis.age = age;\r\n\t}\r\n\tpublic String getName() {\r\n\t\treturn name;\r\n\t}\r\n\tpublic Integer getAge() {\r\n\t\treturn age;\r\n\t}\r\n\tpublic String toString() {\r\n\t\treturn \"Person: name(\" + name + \"), age(\" + age + \")\";\r\n\t}\r\n}\r\n<\/pre>\n
Next, our own message converter.<\/p>\n
PersonMessageConverter:<\/span><\/em><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport javax.jms.JMSException;\r\nimport javax.jms.MapMessage;\r\nimport javax.jms.Message;\r\nimport javax.jms.Session;\r\n\r\nimport org.springframework.jms.support.converter.MessageConversionException;\r\nimport org.springframework.jms.support.converter.MessageConverter;\r\n\r\npublic class PersonMessageConverter implements MessageConverter{\r\n\r\n\tpublic Message toMessage(Object object, Session session)\r\n\t\t\tthrows JMSException, MessageConversionException {\t\t\r\n\t\tPerson person = (Person) object;\r\n\t\tMapMessage message = session.createMapMessage();\r\n\t\tmessage.setString(\"name\", person.getName());\r\n\t\tmessage.setInt(\"age\", person.getAge());\r\n\t\treturn message;\r\n\t}\r\n\r\n\tpublic Object fromMessage(Message message) throws JMSException,\r\n\t\t\tMessageConversionException {\r\n\t\tMapMessage mapMessage = (MapMessage) message;\r\n\t\tPerson person = new Person(mapMessage.getString(\"name\"), mapMessage.getInt(\"age\"));\r\n\t\treturn person;\r\n\t}\r\n\r\n}\r\n<\/pre>\n
The producer will use person object, convert it to a map object an then call getJmsTemplate().convertAndSend(map)<\/code>.<\/p>\n
SpringJmsPersonProducer:<\/span><\/em><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport java.util.HashMap;\r\nimport java.util.Map;\r\n\r\nimport org.springframework.jms.core.support.JmsGatewaySupport;\r\n\r\npublic class SpringJmsPersonProducer extends JmsGatewaySupport {\r\n\tpublic void sendMessage(final Person person) {\r\n\t\tSystem.out.println(\"Producer sends \" + person);\r\n\t\tMap map = new HashMap();\r\n\t\tmap.put(\"name\", person.getName());\r\n\t\tmap.put(\"age\", person.getAge());\r\n\t\tgetJmsTemplate().convertAndSend(map);\t\r\n\t}\r\n}\r\n<\/pre>\n
The consumer will call getJmsTemplate().receiveAndConvert()<\/code> to retrieve the map object and then use it to reconstruct the person object.<\/p>\n
SpringJmsPersonConsumer:<\/span><\/em><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport java.util.Map;\r\n\r\nimport javax.jms.JMSException;\r\n\r\nimport org.springframework.jms.core.support.JmsGatewaySupport;\r\n\r\npublic class SpringJmsPersonConsumer extends JmsGatewaySupport {\r\n\tpublic Person receiveMessage() throws JMSException {\r\n\t\tMap map = (Map) getJmsTemplate().receiveAndConvert();\r\n\t\tPerson person = new Person((String) map.get(\"name\"), (Integer) map.get(\"age\"));\r\n\t\treturn person;\t\r\n\t}\r\n}\r\n<\/pre>\n
We will now configure the above beans in application context.<\/p>\n
applicationContext.xml:<\/em><\/span><\/p>\n
<?xml version=\"1.0\" encoding=\"UTF-8\"?>\r\n<beans xmlns=\"http:\/\/www.springframework.org\/schema\/beans\"\r\n\txmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\r\n\txsi:schemaLocation=\"http:\/\/www.springframework.org\/schema\/beans http:\/\/www.springframework.org\/schema\/beans\/spring-beans.xsd\">\r\n\r\n\t<bean id=\"connectionFactory\" class=\"org.apache.activemq.ActiveMQConnectionFactory\">\r\n\t\t<property name=\"brokerURL\" value=\"tcp:\/\/localhost:61616\" \/>\r\n\t<\/bean>\r\n\t<bean id=\"messageDestination\" class=\"org.apache.activemq.command.ActiveMQQueue\">\r\n\t\t<constructor-arg value=\"messageQueue1\" \/>\r\n\t<\/bean>\r\n\t<bean id=\"jmsTemplate\" class=\"org.springframework.jms.core.JmsTemplate\">\r\n\t\t<property name=\"connectionFactory\" ref=\"connectionFactory\" \/>\r\n\t\t<property name=\"receiveTimeout\" value=\"10000\" \/>\r\n\t<\/bean>\r\n\r\n\t<bean id=\"springJmsProducer\" class=\"com.javacodegeeks.spring.jms.SpringJmsProducer\">\r\n\t\t<property name=\"destination\" ref=\"messageDestination\" \/>\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplate\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsConsumer\" class=\"com.javacodegeeks.spring.jms.SpringJmsConsumer\">\r\n\t\t<property name=\"destination\" ref=\"messageDestination\" \/>\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplate\" \/>\r\n\t<\/bean>\r\n\t\r\n        <bean id=\"jmsTemplateWithDefaultDestination\" class=\"org.springframework.jms.core.JmsTemplate\">\r\n\t\t<property name=\"connectionFactory\" ref=\"connectionFactory\" \/>\r\n\t\t<property name=\"receiveTimeout\" value=\"10000\" \/>\r\n\t\t<property name=\"defaultDestinationName\" value=\"messageQueue2\" \/>\r\n\t<\/bean>\r\n\t\r\n        <bean id=\"springJmsGatewayProducer\" class=\"com.javacodegeeks.spring.jms.SpringJmsGatewayProducer\">\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplateWithDefaultDestination\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsGatewayConsumer\" class=\"com.javacodegeeks.spring.jms.SpringJmsGatewayConsumer\">\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplateWithDefaultDestination\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsPersonProducer\" class=\"com.javacodegeeks.spring.jms.SpringJmsPersonProducer\">\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplateWithDefaultDestination\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"springJmsPersonConsumer\" class=\"com.javacodegeeks.spring.jms.SpringJmsPersonConsumer\">\r\n\t\t<property name=\"jmsTemplate\" ref=\"jmsTemplateWithDefaultDestination\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"jmsTemplateWithMsgConverter\" class=\"org.springframework.jms.core.JmsTemplate\">\r\n\t\t<property name=\"connectionFactory\" ref=\"connectionFactory\" \/>\r\n\t\t<property name=\"receiveTimeout\" value=\"10000\" \/>\r\n\t\t<property name=\"defaultDestinationName\" value=\"messageQueue2\" \/>\r\n\t\t<property name=\"messageConverter\" ref=\"personMessageConverter\" \/>\r\n\t<\/bean>\r\n\t\r\n\t<bean id=\"personMessageConverter\" class=\"com.javacodegeeks.spring.jms.PersonMessageConverter\" \/>\r\n\r\n<\/beans>\r\n<\/pre>\n
Let’s now try to send a person object and receive it back.<\/p>\n
SpringJmsMessageConverterExample:<\/em><\/span><\/p>\n
package com.javacodegeeks.spring.jms;\r\n\r\nimport java.net.URI;\r\nimport java.net.URISyntaxException;\r\n\r\nimport org.apache.activemq.broker.BrokerFactory;\r\nimport org.apache.activemq.broker.BrokerService;\r\nimport org.springframework.context.support.ClassPathXmlApplicationContext;\r\n\r\npublic class SpringJmsMessageConverterExample {\r\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\r\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\r\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\r\n\t\tbroker.start();\r\n\t\tClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(\r\n\t\t\t\t\"applicationContext.xml\");\r\n\r\n\t\ttry {\r\n\t\t\tSpringJmsPersonProducer springJmsProducer = (SpringJmsPersonProducer) context\r\n\t\t\t\t\t.getBean(\"springJmsPersonProducer\");\r\n\t\t\tspringJmsProducer.sendMessage(new Person(\"Joe\", 32));\r\n\r\n\t\t\tSpringJmsPersonConsumer springJmsConsumer = (SpringJmsPersonConsumer) context\r\n\t\t\t\t\t.getBean(\"springJmsPersonConsumer\");\r\n\t\t\tSystem.out.println(\"Consumer receives \" + springJmsConsumer.receiveMessage());\r\n\t\t} finally {\r\n\t\t\tbroker.stop();\r\n\t\t\tcontext.close();\r\n\t\t}\r\n\t}\r\n}\r\n<\/pre>\n
Output:<\/em><\/span><\/p>\n
 INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\r\n INFO | PListStore:[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\tmp_storage] started\r\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\KahaDB]\r\n INFO | KahaDB is version 6\r\n INFO | Recovering from the journal @1:9020\r\n INFO | Recovery replayed 1 operations from the journal in 0.012 seconds.\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-59623-1444923537588-0:1) is starting\r\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\r\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-59623-1444923537588-0:1) started\r\n INFO | For help or more information please see: http:\/\/activemq.apache.org\r\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\KahaDB only has 56887 mb of usable space - resetting to maximum available disk space: 56887 mb\r\nProducer sends Person: name(Joe), age(32)\r\nConsumer receives Person: name(Joe), age(32)\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-59623-1444923537588-0:1) is shutting down\r\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\r\n INFO | PListStore:[C:\\javacodegeeks_ws\\springJmsExample\\activemq-data\\localhost\\tmp_storage] stopped\r\n INFO | Stopping async queue tasks\r\n INFO | Stopping async topic tasks\r\n INFO | Stopped KahaDB\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-59623-1444923537588-0:1) uptime 1.406 seconds\r\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-59623-1444923537588-0:1) is shutdown\r\n<\/pre>\n
6. Download Eclipse Project<\/h2>\n
This was an example about Spring JMS. <\/p>\n
Download<\/strong>
You can download the full source code of this example here: springJmsExample.zip<\/strong><\/a><\/div>\n","protected":false},"excerpt":{"rendered":"
Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another layer around the JMS layer. This layer provides convenience methods for sending and receiving messages, as well as manages the creation and release of resources like the connection object. The …<\/p>\n","protected":false},"author":38,"featured_media":1248,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[52],"tags":[],"class_list":["post-27968","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-spring"],"yoast_head":"\nSpring JMS Example - Java Code Geeks<\/title>\n<meta name=\"description\" content=\"Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another\" \/>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\" \/>\n<meta property=\"og:locale\" content=\"en_US\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Spring JMS Example - Java Code Geeks\" \/>\n<meta property=\"og:description\" content=\"Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another\" \/>\n<meta property=\"og:url\" content=\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\" \/>\n<meta property=\"og:site_name\" content=\"Examples Java Code Geeks\" \/>\n<meta property=\"article:publisher\" content=\"https:\/\/www.facebook.com\/javacodegeeks\" \/>\n<meta property=\"article:published_time\" content=\"2015-10-16T12:00:39+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg\" \/>\n\t<meta property=\"og:image:width\" content=\"150\" \/>\n\t<meta property=\"og:image:height\" content=\"150\" \/>\n\t<meta property=\"og:image:type\" content=\"image\/jpeg\" \/>\n<meta name=\"author\" content=\"Ram Mokkapaty\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:creator\" content=\"@javacodegeeks\" \/>\n<meta name=\"twitter:site\" content=\"@javacodegeeks\" \/>\n<meta name=\"twitter:label1\" content=\"Written by\" \/>\n\t<meta name=\"twitter:data1\" content=\"Ram Mokkapaty\" \/>\n\t<meta name=\"twitter:label2\" content=\"Est. reading time\" \/>\n\t<meta name=\"twitter:data2\" content=\"16 minutes\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"Article\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#article\",\"isPartOf\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\"},\"author\":{\"name\":\"Ram Mokkapaty\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/#\/schema\/person\/7b1823eb5bd673bd375f8bee33b70cd8\"},\"headline\":\"Spring JMS Example\",\"datePublished\":\"2015-10-16T12:00:39+00:00\",\"mainEntityOfPage\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\"},\"wordCount\":835,\"commentCount\":2,\"publisher\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/#organization\"},\"image\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage\"},\"thumbnailUrl\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg\",\"articleSection\":[\"spring\"],\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"CommentAction\",\"name\":\"Comment\",\"target\":[\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#respond\"]}]},{\"@type\":\"WebPage\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\",\"url\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\",\"name\":\"Spring JMS Example - Java Code Geeks\",\"isPartOf\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/#website\"},\"primaryImageOfPage\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage\"},\"image\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage\"},\"thumbnailUrl\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg\",\"datePublished\":\"2015-10-16T12:00:39+00:00\",\"description\":\"Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another\",\"breadcrumb\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#breadcrumb\"},\"inLanguage\":\"en-US\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/\"]}]},{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage\",\"url\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg\",\"contentUrl\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg\",\"width\":150,\"height\":150},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"Home\",\"item\":\"https:\/\/examples.javacodegeeks.com\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Java Development\",\"item\":\"https:\/\/examples.javacodegeeks.com\/category\/java-development\/\"},{\"@type\":\"ListItem\",\"position\":3,\"name\":\"Enterprise Java\",\"item\":\"https:\/\/examples.javacodegeeks.com\/category\/java-development\/enterprise-java\/\"},{\"@type\":\"ListItem\",\"position\":4,\"name\":\"spring\",\"item\":\"https:\/\/examples.javacodegeeks.com\/category\/java-development\/enterprise-java\/spring\/\"},{\"@type\":\"ListItem\",\"position\":5,\"name\":\"Spring JMS Example\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/#website\",\"url\":\"https:\/\/examples.javacodegeeks.com\/\",\"name\":\"Java Code Geeks\",\"description\":\"Java Examples and Code Snippets\",\"publisher\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/#organization\"},\"alternateName\":\"JCG\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/examples.javacodegeeks.com\/?s={search_term_string}\"},\"query-input\":{\"@type\":\"PropertyValueSpecification\",\"valueRequired\":true,\"valueName\":\"search_term_string\"}}],\"inLanguage\":\"en-US\"},{\"@type\":\"Organization\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/#organization\",\"name\":\"Exelixis Media P.C.\",\"url\":\"https:\/\/examples.javacodegeeks.com\/\",\"logo\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/#\/schema\/logo\/image\/\",\"url\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png\",\"contentUrl\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png\",\"width\":864,\"height\":246,\"caption\":\"Exelixis Media P.C.\"},\"image\":{\"@id\":\"https:\/\/examples.javacodegeeks.com\/#\/schema\/logo\/image\/\"},\"sameAs\":[\"https:\/\/www.facebook.com\/javacodegeeks\",\"https:\/\/x.com\/javacodegeeks\"]},{\"@type\":\"Person\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/#\/schema\/person\/7b1823eb5bd673bd375f8bee33b70cd8\",\"name\":\"Ram Mokkapaty\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"en-US\",\"@id\":\"https:\/\/examples.javacodegeeks.com\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2014\/12\/Ram-Mokkapaty-96x96.jpg\",\"contentUrl\":\"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2014\/12\/Ram-Mokkapaty-96x96.jpg\",\"caption\":\"Ram Mokkapaty\"},\"description\":\"Ram holds a master's degree in Machine Design from IT B.H.U. His expertise lies in test driven development and re-factoring. He is passionate about open source technologies and actively blogs on various java and open-source technologies like spring. He works as a principal Engineer in the logistics domain.\",\"sameAs\":[\"http:\/\/www.javacodegeeks.com\/\",\"https:\/\/in.linkedin.com\/pub\/ram-satish-mokkapaty\/18\/123\/52b\"],\"url\":\"https:\/\/examples.javacodegeeks.com\/author\/ram-mokkapaty\/\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Spring JMS Example - Java Code Geeks","description":"Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/","og_locale":"en_US","og_type":"article","og_title":"Spring JMS Example - Java Code Geeks","og_description":"Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another","og_url":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/","og_site_name":"Examples Java Code Geeks","article_publisher":"https:\/\/www.facebook.com\/javacodegeeks","article_published_time":"2015-10-16T12:00:39+00:00","og_image":[{"width":150,"height":150,"url":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg","type":"image\/jpeg"}],"author":"Ram Mokkapaty","twitter_card":"summary_large_image","twitter_creator":"@javacodegeeks","twitter_site":"@javacodegeeks","twitter_misc":{"Written by":"Ram Mokkapaty","Est. reading time":"16 minutes"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"Article","@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#article","isPartOf":{"@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/"},"author":{"name":"Ram Mokkapaty","@id":"https:\/\/examples.javacodegeeks.com\/#\/schema\/person\/7b1823eb5bd673bd375f8bee33b70cd8"},"headline":"Spring JMS Example","datePublished":"2015-10-16T12:00:39+00:00","mainEntityOfPage":{"@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/"},"wordCount":835,"commentCount":2,"publisher":{"@id":"https:\/\/examples.javacodegeeks.com\/#organization"},"image":{"@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage"},"thumbnailUrl":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg","articleSection":["spring"],"inLanguage":"en-US","potentialAction":[{"@type":"CommentAction","name":"Comment","target":["https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#respond"]}]},{"@type":"WebPage","@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/","url":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/","name":"Spring JMS Example - Java Code Geeks","isPartOf":{"@id":"https:\/\/examples.javacodegeeks.com\/#website"},"primaryImageOfPage":{"@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage"},"image":{"@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage"},"thumbnailUrl":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg","datePublished":"2015-10-16T12:00:39+00:00","description":"Java Messaging Service (JMS) is a standard messaging API used to send and receive messages. Spring simplifies the use of JMS API by providing another","breadcrumb":{"@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#breadcrumb"},"inLanguage":"en-US","potentialAction":[{"@type":"ReadAction","target":["https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/"]}]},{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#primaryimage","url":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg","contentUrl":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2012\/12\/spring-logo.jpg","width":150,"height":150},{"@type":"BreadcrumbList","@id":"https:\/\/examples.javacodegeeks.com\/java-development\/enterprise-java\/spring\/spring-jms-example\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"Home","item":"https:\/\/examples.javacodegeeks.com\/"},{"@type":"ListItem","position":2,"name":"Java Development","item":"https:\/\/examples.javacodegeeks.com\/category\/java-development\/"},{"@type":"ListItem","position":3,"name":"Enterprise Java","item":"https:\/\/examples.javacodegeeks.com\/category\/java-development\/enterprise-java\/"},{"@type":"ListItem","position":4,"name":"spring","item":"https:\/\/examples.javacodegeeks.com\/category\/java-development\/enterprise-java\/spring\/"},{"@type":"ListItem","position":5,"name":"Spring JMS Example"}]},{"@type":"WebSite","@id":"https:\/\/examples.javacodegeeks.com\/#website","url":"https:\/\/examples.javacodegeeks.com\/","name":"Java Code Geeks","description":"Java Examples and Code Snippets","publisher":{"@id":"https:\/\/examples.javacodegeeks.com\/#organization"},"alternateName":"JCG","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/examples.javacodegeeks.com\/?s={search_term_string}"},"query-input":{"@type":"PropertyValueSpecification","valueRequired":true,"valueName":"search_term_string"}}],"inLanguage":"en-US"},{"@type":"Organization","@id":"https:\/\/examples.javacodegeeks.com\/#organization","name":"Exelixis Media P.C.","url":"https:\/\/examples.javacodegeeks.com\/","logo":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/examples.javacodegeeks.com\/#\/schema\/logo\/image\/","url":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png","contentUrl":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2022\/06\/exelixis-logo.png","width":864,"height":246,"caption":"Exelixis Media P.C."},"image":{"@id":"https:\/\/examples.javacodegeeks.com\/#\/schema\/logo\/image\/"},"sameAs":["https:\/\/www.facebook.com\/javacodegeeks","https:\/\/x.com\/javacodegeeks"]},{"@type":"Person","@id":"https:\/\/examples.javacodegeeks.com\/#\/schema\/person\/7b1823eb5bd673bd375f8bee33b70cd8","name":"Ram Mokkapaty","image":{"@type":"ImageObject","inLanguage":"en-US","@id":"https:\/\/examples.javacodegeeks.com\/#\/schema\/person\/image\/","url":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2014\/12\/Ram-Mokkapaty-96x96.jpg","contentUrl":"https:\/\/examples.javacodegeeks.com\/wp-content\/uploads\/2014\/12\/Ram-Mokkapaty-96x96.jpg","caption":"Ram Mokkapaty"},"description":"Ram holds a master's degree in Machine Design from IT B.H.U. His expertise lies in test driven development and re-factoring. He is passionate about open source technologies and actively blogs on various java and open-source technologies like spring. He works as a principal Engineer in the logistics domain.","sameAs":["http:\/\/www.javacodegeeks.com\/","https:\/\/in.linkedin.com\/pub\/ram-satish-mokkapaty\/18\/123\/52b"],"url":"https:\/\/examples.javacodegeeks.com\/author\/ram-mokkapaty\/"}]}},"_links":{"self":[{"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/posts\/27968","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/users\/38"}],"replies":[{"embeddable":true,"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/comments?post=27968"}],"version-history":[{"count":0,"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/posts\/27968\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/media\/1248"}],"wp:attachment":[{"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/media?parent=27968"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/categories?post=27968"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/examples.javacodegeeks.com\/wp-json\/wp\/v2\/tags?post=27968"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}