JMS Message queue is a destination to which producers send messages. Consumer connects to the broker to receive the message sitting in the queue. Queue is used in point-to-point messaging. In point-to-point messaging, there may be more than one receiver connected to the queue but each message in the queue may only be consumed by one of the queue’s receivers.<\/p>\n
The messages can be sent and received either synchronously or asynchronously.<\/p>\n
In this article, we will see some examples of JMS Queue.<\/p>\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 First let’s see how to create a queue.<\/p>\n In order to create a queue object, you need to first create a session and then call The queue stores all messages until they\u2019re delivered or until they expire.<\/p>\n Now that we have a queue object, let’s send a message to it.<\/p>\n As you can see from above, a producer sends a message to the queue.<\/p>\n Each message received on the queue is delivered once and only once to a single consumer which is why this style of messaging is called point-to-point messaging. Consumer will first connect to the broker to receive the message from the queue. Just like the producer, consumer also needs a session using which it will connect to the queue.<\/p>\n Note that connection is started so that any message listener registered will get the notification as soon as a message lands in the queue.<\/p>\n Consumer receives the message using JmsMessageQueueExample:<\/em><\/span><\/p>\n Output:<\/em><\/span><\/p>\n In our last example, we have seen consumer receiving message explicitly using MessageConsumer.receive(). In in this section, we will see ow a consumer can register a message listener. Instead of explicitly receiving the message, consumer just registers a message listener. Moment a message lands in the queue, the broker passes on the message to one of the message listeners. Let’s first create a message listener.<\/p>\n A message listener is created by implementing ConsumerMessageListener:<\/em><\/span><\/p>\n Consumer will register its own message listener. It will pass a name to it so we know which consumer is consuming the message.<\/p>\n Next, we need to make sure JmsMessageAsynchronousQueueExample:<\/em><\/span><\/p>\n Output:<\/em><\/span><\/p>\n The workload of message processing can be distributed among more than one consumer. When multiple receivers are attached to a queue, each message in the queue is delivered to one receiver. The absolute order of messages cannot be guaranteed, since one receiver may process messages faster than another.<\/p>\n Storage for queue is on the basis of first in, first out order (FIFO). One message is dispatched to a single consumer at a time. Only when that message has been consumed and acknowledged, it is deleted from the queue. Each consumer will register its own message listener. It will pass a name to it so we know which consumer is consuming the message.<\/p>\n JmsMultipleCustomersMessageQueueExample:<\/em><\/span><\/p>\n You can see from output, the messages are delivered in a round-robin fashion between all the message consumers.[ulp id=’meNHaG2axN7AsWAw’]<\/p>\n Output:<\/em><\/span><\/p>\n A temporary queue is a queue which can only be consumed by the JMS client that created it. It is created using the JMS allows you to peek ahead at pending messages on a Queue without actually consuming them using We create the As you can see To enumerate through the messages, we will call When we are done with the browser we should close it.<\/p>\n In the below example, we create a producer and post a bunch of messages to a queue. Next we create a consumer. In order to browse, we create a Finally, we call Messages obtained from a QueueBrowser are copies of messages contained in the queue and are not considered to be consumed as they are merely for browsing. Below is the output.<\/p>\n Output:<\/em><\/span><\/p>\n This was an example about JMS Queue.<\/p>\n<project xmlns=\"http:\/\/maven.apache.org\/POM\/4.0.0\" xmlns:xsi=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"\n\txsi:schemaLocation=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\">\n\t<modelVersion>4.0.0<\/modelVersion>\n\t<groupId>com.javacodegeeks.jms<\/groupId>\n\t<artifactId>springJmsQueue<\/artifactId>\n\t<version>0.0.1-SNAPSHOT<\/version>\n\t<dependencies>\n\t\t<dependency>\n\t\t\t<groupId>org.apache.activemq<\/groupId>\n\t\t\t<artifactId>activemq-all<\/artifactId>\n\t\t\t<version>5.12.0<\/version>\n\t\t<\/dependency>\n\t<\/dependencies>\n\t\n<\/project>\n<\/pre>\n<\/p>\n
2. Creating a Queue<\/h2>\n
createQueue()<\/code> on the session object. You need to pass the queue name to it.<\/p>\nSession session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);\nQueue queue = session.createQueue(\"customerQueue\");\n<\/pre>\n
3. Sending message to a Queue<\/h2>\n
MessageProducer producer = session.createProducer(queue);\nproducer.send(msg);\n<\/pre>\n
4. Receive message from Queue<\/h2>\n
MessageConsumer consumer = session.createConsumer(queue);\nconnection.start();\n<\/pre>\n
MessageConsumer.receive()<\/code> method or asynchronously by registering a MessageListener<\/code> implementation using the MessageConsumer.setMessageListener()<\/code> method. Multiple consumers can be registered on a single queue but only one consumer will receive a given message.<\/p>\nTextMessage textMsg = (TextMessage) consumer.receive();\nSystem.out.println(textMsg);\nSystem.out.println(\"Received: \" + textMsg.getText());\n<\/pre>\n
package com.javacodegeeks.jms;\n\nimport java.net.URI;\nimport java.net.URISyntaxException;\n\nimport javax.jms.Connection;\nimport javax.jms.ConnectionFactory;\nimport javax.jms.Message;\nimport javax.jms.MessageConsumer;\nimport javax.jms.MessageProducer;\nimport javax.jms.Queue;\nimport javax.jms.Session;\nimport javax.jms.TextMessage;\n\nimport org.apache.activemq.ActiveMQConnectionFactory;\nimport org.apache.activemq.broker.BrokerFactory;\nimport org.apache.activemq.broker.BrokerService;\n\npublic class JmsMessageQueueExample {\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\n\t\tbroker.start();\n\t\tConnection connection = null;\n\t\ttry {\n\t\t\t\/\/ Producer\n\t\t\tConnectionFactory connectionFactory = new ActiveMQConnectionFactory(\n\t\t\t\t\t\"tcp:\/\/localhost:61616\");\n\t\t\tconnection = connectionFactory.createConnection();\n\t\t\tSession session = connection.createSession(false,\n\t\t\t\t\tSession.AUTO_ACKNOWLEDGE);\n\t\t\tQueue queue = session.createQueue(\"customerQueue\");\n\t\t\tString payload = \"Important Task\";\n\t\t\tMessage msg = session.createTextMessage(payload);\n\t\t\tMessageProducer producer = session.createProducer(queue);\n\t\t\tSystem.out.println(\"Sending text '\" + payload + \"'\");\n\t\t\tproducer.send(msg);\n\n\t\t\t\/\/ Consumer\n\t\t\tMessageConsumer consumer = session.createConsumer(queue);\n\t\t\tconnection.start();\n\t\t\tTextMessage textMsg = (TextMessage) consumer.receive();\n\t\t\tSystem.out.println(textMsg);\n\t\t\tSystem.out.println(\"Received: \" + textMsg.getText());\n\t\t\tsession.close();\n\t\t} finally {\n\t\t\tif (connection != null) {\n\t\t\t\tconnection.close();\n\t\t\t}\n broker.stop();\n\t\t}\n\t}\n\n}\n<\/pre>\n INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] started\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB]\n INFO | KahaDB is version 6\n INFO | Recovering from the journal @1:169756\n INFO | Recovery replayed 1 operations from the journal in 0.011 seconds.\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-57715-1446468253396-0:1) is starting\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-57715-1446468253396-0:1) started\n INFO | For help or more information please see: http:\/\/activemq.apache.org\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB only has 34512 mb of usable space - resetting to maximum available disk space: 34512 mb\n WARN | Temporary Store limit is 51200 mb, whilst the temporary data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage only has 34512 mb of usable space - resetting to maximum available 34512 mb.\nSending text 'Important Task'\nActiveMQTextMessage {commandId = 5, responseRequired = true, messageId = ID:INMAA1-L1005-57715-1446468253396-3:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:INMAA1-L1005-57715-1446468253396-3:1:1:1, destination = queue:\/\/customerQueue, transactionId = null, expiration = 0, timestamp = 1446468253638, arrival = 0, brokerInTime = 1446468253639, brokerOutTime = 1446468253663, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@77be656f, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false, text = Important Task}\nReceived: Important Task\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-57715-1446468253396-0:1) is shutting down\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] stopped\n INFO | Stopping async queue tasks\n INFO | Stopping async topic tasks\n INFO | Stopped KahaDB\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-57715-1446468253396-0:1) uptime 0.906 seconds\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-57715-1446468253396-0:1) is shutdown\n<\/pre>\n5. Receiving a message Asynchronously<\/h2>\n
javax.jms.MessageListener<\/code> and implementing onMessage(Message)<\/code>.<\/p>\npackage com.javacodegeeks.jms;\n\nimport javax.jms.JMSException;\nimport javax.jms.Message;\nimport javax.jms.MessageListener;\nimport javax.jms.TextMessage;\n\npublic class ConsumerMessageListener implements MessageListener {\n\tprivate String consumerName;\n\tpublic ConsumerMessageListener(String consumerName) {\n\t\tthis.consumerName = consumerName;\n\t}\n\n\tpublic void onMessage(Message message) {\n\t\tTextMessage textMessage = (TextMessage) message;\n\t\ttry {\n\t\t\tSystem.out.println(consumerName + \" received \" + textMessage.getText());\n\t\t} catch (JMSException e) {\t\t\t\n\t\t\te.printStackTrace();\n\t\t}\n\t}\n\n}\n<\/pre>\n\/\/ Consumer\nMessageConsumer consumer = session.createConsumer(queue);\nconsumer.setMessageListener(new ConsumerMessageListener(\"Consumer\"));\n<\/pre>\n
start()<\/code> is called on connection object. This is an important step for the broker to make sure the message is passed on to one of the listeners.<\/p>\nconnection.start();\n<\/pre>\n
package com.javacodegeeks.jms;\n\nimport java.net.URI;\nimport java.net.URISyntaxException;\n\nimport javax.jms.Connection;\nimport javax.jms.ConnectionFactory;\nimport javax.jms.Message;\nimport javax.jms.MessageConsumer;\nimport javax.jms.MessageProducer;\nimport javax.jms.Queue;\nimport javax.jms.Session;\n\nimport org.apache.activemq.ActiveMQConnectionFactory;\nimport org.apache.activemq.broker.BrokerFactory;\nimport org.apache.activemq.broker.BrokerService;\n\npublic class JmsMessageAsynchronousQueueExample {\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\n\t\tbroker.start();\n\t\tConnection connection = null;\n\t\ttry {\n\t\t\t\/\/ Producer\n\t\t\tConnectionFactory connectionFactory = new ActiveMQConnectionFactory(\n\t\t\t\t\t\"tcp:\/\/localhost:61616\");\n\t\t\tconnection = connectionFactory.createConnection();\n\t\t\tSession session = connection.createSession(false,\n\t\t\t\t\tSession.AUTO_ACKNOWLEDGE);\n\t\t\tQueue queue = session.createQueue(\"customerQueue\");\n\t\t\tString payload = \"Important Task\";\n\t\t\tMessage msg = session.createTextMessage(payload);\n\t\t\tMessageProducer producer = session.createProducer(queue);\n\t\t\tSystem.out.println(\"Sending text '\" + payload + \"'\");\n\t\t\tproducer.send(msg);\n\n\t\t\t\/\/ Consumer\n\t\t\tMessageConsumer consumer = session.createConsumer(queue);\n\t\t\tconsumer.setMessageListener(new ConsumerMessageListener(\"Consumer\"));\n\t\t\tconnection.start();\n\t\t\tThread.sleep(1000);\n\t\t\tsession.close();\n\t\t} finally {\n\t\t\tif (connection != null) {\n\t\t\t\tconnection.close();\n\t\t\t}\n\t\t\tbroker.stop();\n\t\t}\n\t}\n\n}\n<\/pre>\n INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] started\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB]\n INFO | KahaDB is version 6\n INFO | Recovering from the journal @1:153817\n INFO | Recovery replayed 1 operations from the journal in 0.011 seconds.\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56230-1446467650870-0:1) is starting\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56230-1446467650870-0:1) started\n INFO | For help or more information please see: http:\/\/activemq.apache.org\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB only has 34515 mb of usable space - resetting to maximum available disk space: 34515 mb\n WARN | Temporary Store limit is 51200 mb, whilst the temporary data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage only has 34515 mb of usable space - resetting to maximum available 34515 mb.\nSending text 'Important Task'\nConsumer received Important Task\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56230-1446467650870-0:1) is shutting down\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] stopped\n INFO | Stopping async queue tasks\n INFO | Stopping async topic tasks\n INFO | Stopped KahaDB\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56230-1446467650870-0:1) uptime 1.928 seconds\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-56230-1446467650870-0:1) is shutdown\n<\/pre>\n
6. Multiple Consumers<\/h2>\n
\nIn the below example, we create multiple consumers, each one registered with a message listener. Next, we create a producer and make it send multiple messages. Each message is received by just one consumer and the order in which the messages are received is according to FIFO.<\/p>\npackage com.javacodegeeks.jms;\n\nimport java.net.URI;\nimport java.net.URISyntaxException;\n\nimport javax.jms.Connection;\nimport javax.jms.ConnectionFactory;\nimport javax.jms.Message;\nimport javax.jms.MessageConsumer;\nimport javax.jms.MessageProducer;\nimport javax.jms.Queue;\nimport javax.jms.Session;\n\nimport org.apache.activemq.ActiveMQConnectionFactory;\nimport org.apache.activemq.broker.BrokerFactory;\nimport org.apache.activemq.broker.BrokerService;\n\npublic class JmsMultipleCustomersMessageQueueExample {\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\n\t\tbroker.start();\n\t\tConnection connection = null;\n\t\ttry {\n\t\t\t\/\/ Producer\n\t\t\tConnectionFactory connectionFactory = new ActiveMQConnectionFactory(\n\t\t\t\t\t\"tcp:\/\/localhost:61616\");\n\t\t\tconnection = connectionFactory.createConnection();\n\t\t\tSession session = connection.createSession(false,\n\t\t\t\t\tSession.AUTO_ACKNOWLEDGE);\n\t\t\tQueue queue = session.createQueue(\"customerQueue\");\n\n\t\t\t\/\/ Consumer\n\t\t\tfor (int i = 0; i < 4; i++) {\n\t\t\t\tMessageConsumer consumer = session.createConsumer(queue);\n\t\t\t\tconsumer.setMessageListener(new ConsumerMessageListener(\n\t\t\t\t\t\t\"Consumer \" + i));\n\t\t\t}\n\t\t\tconnection.start();\n\n\t\t\tString basePayload = \"Important Task\";\n\t\t\tMessageProducer producer = session.createProducer(queue);\n\t\t\tfor (int i = 0; i < 10; i++) {\n\t\t\t\tString payload = basePayload + i;\n\t\t\t\tMessage msg = session.createTextMessage(payload);\n\t\t\t\tSystem.out.println(\"Sending text '\" + payload + \"'\");\n\t\t\t\tproducer.send(msg);\n\t\t\t}\n\n\t\t\tThread.sleep(1000);\n\t\t\tsession.close();\n\t\t} finally {\n\t\t\tif (connection != null) {\n\t\t\t\tconnection.close();\n\t\t\t}\n\t\t\tbroker.stop();\n\t\t}\n\t}\n\n}\n<\/pre>\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] started\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB]\n INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\n INFO | KahaDB is version 6\n INFO | Recovering from the journal @1:173161\n INFO | Recovery replayed 1 operations from the journal in 0.012 seconds.\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-62099-1446469937715-0:1) is starting\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-62099-1446469937715-0:1) started\n INFO | For help or more information please see: http:\/\/activemq.apache.org\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB only has 34555 mb of usable space - resetting to maximum available disk space: 34556 mb\n WARN | Temporary Store limit is 51200 mb, whilst the temporary data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage only has 34555 mb of usable space - resetting to maximum available 34555 mb.\nSending text 'Important Task0'\nConsumer 0 received Important Task0\nSending text 'Important Task1'\nConsumer 1 received Important Task1\nSending text 'Important Task2'\nConsumer 2 received Important Task2\nSending text 'Important Task3'\nConsumer 3 received Important Task3\nSending text 'Important Task4'\nConsumer 0 received Important Task4\nSending text 'Important Task5'\nConsumer 1 received Important Task5\nSending text 'Important Task6'\nConsumer 2 received Important Task6\nSending text 'Important Task7'\nConsumer 3 received Important Task7\nSending text 'Important Task8'\nConsumer 0 received Important Task8\nSending text 'Important Task9'\nConsumer 1 received Important Task9\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-62099-1446469937715-0:1) is shutting down\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] stopped\n INFO | Stopping async queue tasks\n INFO | Stopping async topic tasks\n INFO | Stopped KahaDB\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-62099-1446469937715-0:1) uptime 2.009 seconds\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-62099-1446469937715-0:1) is shutdown\n<\/pre>\n
7. Creating a Temporary Queue<\/h2>\n
createTemporaryQueue()<\/code> method on QueueSession\/code> object.<\/code><\/p>\nQueueSession.createTemporaryQueue();\n<\/pre>\n
8. Browsing a Queue<\/h2>\n
QueueBrowser<\/code> object. Since we can browse through the messages without actually consuming them, this is very unique and important feature to point-to-point messaging.<\/p>\nQueueBrowser<\/code> object using the below statement on session object.<\/p>\nQueueBrowser browser = session.createBrowser(queue);\n<\/pre>\n
createBrowser()<\/code> takes the Queue<\/code> object that we are interested to browse.<\/p>\nQueueBrowser.getEnumeration()<\/code>.<\/p>\nEnumeration e = browser.getEnumeration();\nwhile (e.hasMoreElements()) {\n TextMessage message = (TextMessage) e.nextElement();\n System.out.println(\"Get [\" + message.getText() + \"]\");\n}\n<\/pre>\nQueueBrowser.close();\n<\/pre>\n
QueueBrowser<\/code> object and navigate through the messages.<\/p>\nconsumer.receive()<\/code> to receive one of the messages from queue.<\/p>\npackage com.javacodegeeks.jms;\n\nimport java.net.URI;\nimport java.net.URISyntaxException;\nimport java.util.Enumeration;\n\nimport javax.jms.Connection;\nimport javax.jms.ConnectionFactory;\nimport javax.jms.Message;\nimport javax.jms.MessageConsumer;\nimport javax.jms.MessageProducer;\nimport javax.jms.Queue;\nimport javax.jms.QueueBrowser;\nimport javax.jms.Session;\nimport javax.jms.TextMessage;\n\nimport org.apache.activemq.ActiveMQConnectionFactory;\nimport org.apache.activemq.broker.BrokerFactory;\nimport org.apache.activemq.broker.BrokerService;\n\npublic class JmsBrowseQueueExample {\n\tpublic static void main(String[] args) throws URISyntaxException, Exception {\n\t\tBrokerService broker = BrokerFactory.createBroker(new URI(\n\t\t\t\t\"broker:(tcp:\/\/localhost:61616)\"));\n\t\tbroker.start();\n\t\tConnection connection = null;\n\t\ttry {\n\t\t\t\/\/ Producer\n\t\t\tConnectionFactory connectionFactory = new ActiveMQConnectionFactory(\n\t\t\t\t\t\"tcp:\/\/localhost:61616\");\n\t\t\tconnection = connectionFactory.createConnection();\n\t\t\tSession session = connection.createSession(false,\n\t\t\t\t\tSession.AUTO_ACKNOWLEDGE);\n\t\t\tQueue queue = session.createQueue(\"browseQueue\");\n\n\t\t\tString basePayload = \"A\";\n\t\t\tMessageProducer producer = session.createProducer(queue);\n\t\t\tfor (int i = 0; i < 4; i++) {\n\t\t\t\tString payload = basePayload + i;\n\t\t\t\tMessage msg = session.createTextMessage(payload);\n\t\t\t\tSystem.out.println(\"Sending text '\" + payload + \"'\");\n\t\t\t\tproducer.send(msg);\n\t\t\t}\n\n\t\t\tMessageConsumer consumer = session.createConsumer(queue);\n\t\t\tconnection.start();\n\t\t\t\n\t\t\tSystem.out.println(\"Browse through the elements in queue\");\n\t\t\tQueueBrowser browser = session.createBrowser(queue);\n\t\t\tEnumeration e = browser.getEnumeration();\n\t\t\twhile (e.hasMoreElements()) {\n\t\t\t\tTextMessage message = (TextMessage) e.nextElement();\n\t\t\t\tSystem.out.println(\"Get [\" + message.getText() + \"]\");\n\t\t\t}\n\t\t\tSystem.out.println(\"Done\");\n\t\t\tbrowser.close();\n\t\t\t\n\t\t\tTextMessage textMsg = (TextMessage) consumer.receive();\n\t\t\tSystem.out.println(textMsg);\n\t\t\tSystem.out.println(\"Received: \" + textMsg.getText());\n\t\t\tsession.close();\n\t\t} finally {\n\t\t\tif (connection != null) {\n\t\t\t\tconnection.close();\n\t\t\t}\n\t\t\tbroker.stop();\n\t\t}\n\t}\n\n}\n<\/pre>\n INFO | JMX consoles can connect to service:jmx:rmi:\/\/\/jndi\/rmi:\/\/localhost:1099\/jmxrmi\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] started\n INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB]\n INFO | KahaDB is version 6\n INFO | Recovering from the journal @1:260856\n INFO | Recovery replayed 1 operations from the journal in 0.012 seconds.\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-53401-1446474681874-0:1) is starting\n INFO | Listening for connections at: tcp:\/\/127.0.0.1:61616\n INFO | Connector tcp:\/\/127.0.0.1:61616 started\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-53401-1446474681874-0:1) started\n INFO | For help or more information please see: http:\/\/activemq.apache.org\n WARN | Store limit is 102400 mb (current store usage is 0 mb). The data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\KahaDB only has 34326 mb of usable space - resetting to maximum available disk space: 34327 mb\n WARN | Temporary Store limit is 51200 mb, whilst the temporary data directory: C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage only has 34326 mb of usable space - resetting to maximum available 34326 mb.\nSending text 'A0'\nSending text 'A1'\nSending text 'A2'\nSending text 'A3'\nBrowse through the elements in queue\nGet [A0]\nGet [A1]\nGet [A2]\nGet [A3]\nDone\nActiveMQTextMessage {commandId = 5, responseRequired = true, messageId = ID:INMAA1-L1005-53401-1446474681874-3:1:1:1:1, originalDestination = null, originalTransactionId = null, producerId = ID:INMAA1-L1005-53401-1446474681874-3:1:1:1, destination = queue:\/\/browseQueue, transactionId = null, expiration = 0, timestamp = 1446474682340, arrival = 0, brokerInTime = 1446474682341, brokerOutTime = 1446474682383, correlationId = null, replyTo = null, persistent = true, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = org.apache.activemq.util.ByteSequence@ba8d91c, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = true, readOnlyBody = true, droppable = false, jmsXGroupFirstForConsumer = false, text = A0}\nReceived: A0\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-53401-1446474681874-0:1) is shutting down\n INFO | Connector tcp:\/\/127.0.0.1:61616 stopped\n INFO | PListStore:[C:\\javacodegeeks_ws\\jmsMessageTypesExample\\activemq-data\\localhost\\tmp_storage] stopped\n INFO | Stopping async queue tasks\n INFO | Stopping async topic tasks\n INFO | Stopped KahaDB\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-53401-1446474681874-0:1) uptime 1.446 seconds\n INFO | Apache ActiveMQ 5.12.0 (localhost, ID:INMAA1-L1005-53401-1446474681874-0:1) is shutdown\n<\/pre>\n9. Download the Eclipse Project<\/h2>\n