activemq example

whatsmars-mq/pom.xml

@@ -31,6 +31,19 @@
             <version>4.0.0-incubating</version>
         </dependency>
 
+        <dependency>
+            <groupId>org.apache.activemq</groupId>
+            <artifactId>activemq-client</artifactId>
+            <version>5.11.1</version>
+        </dependency>
+
+
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-jms</artifactId>
+            <version>${spring.version}</version>
+        </dependency>
+
     </dependencies>
 
 

whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/activemq/Consumer.java

+package com.itlong.whatsmars.mq.activemq;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+import javax.jms.*;
+
+/**
+ * Created by shenhongxi on 2017/9/8.
+ */
+public class Consumer {
+
+    public static void main(String[] args) throws Exception {
+        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
+        Connection connection = factory.createConnection();
+        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Queue queue = session.createQueue("TEST.QUEUE");
+        MessageConsumer consumer = session.createConsumer(queue);
+        consumer.setMessageListener(new MessageListener() {
+            @Override
+            public void onMessage(Message message) {
+                System.out.println(message);
+            }
+        });
+
+        connection.start();
+    }
+}

whatsmars-mq/src/main/java/com/itlong/whatsmars/mq/activemq/Producer.java

+package com.itlong.whatsmars.mq.activemq;
+
+import org.apache.activemq.ActiveMQConnectionFactory;
+
+import javax.jms.*;
+
+/**
+ * Created by shenhongxi on 2017/9/8.
+ */
+public class Producer {
+
+    public static void main(String[] args) throws Exception {
+        ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
+        Connection connection = factory.createConnection();
+        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        Queue queue = session.createQueue("TEST.QUEUE");
+        MessageProducer producer = session.createProducer(queue);
+        producer.setDeliveryMode(DeliveryMode.PERSISTENT);
+        for (int i= 0; i < 100; i++) {
+            TextMessage message = session.createTextMessage("hello world! " + i);
+            producer.send(message);
+            System.out.println(message);
+        }
+        producer.close();
+    }
+}