optimise

pom.xml

@@ -223,7 +223,9 @@
 
     <scm>
         <url>https://github.com/javahongxi/whatsmars</url>
-        <connection>https://github.com/javahongxi/whatsmars.git</connection>
+        <connection>scm:git:https://github.com/javahongxi/whatsmars.git</connection>
+        <developerConnection>scm:git:https://github.com/javahongxi/whatsmars.git</developerConnection>
+        <tag>HEAD</tag>
     </scm>
 
     <build>

whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/Consumer.java

-package org.hongxi.whatsmars.rabbitmq;
-
-import com.rabbitmq.client.Channel;
-import com.rabbitmq.client.Connection;
-import com.rabbitmq.client.ConnectionFactory;
-import com.rabbitmq.client.QueueingConsumer;
-
-/**
- * Created by shenhongxi on 2017/9/8.
- */
-public class Consumer {
-
-    public static void main(String[] args) throws Exception {
-        String queueName = "TestQueue";
-        ConnectionFactory factory = new ConnectionFactory();
-        factory.setHost("127.0.0.1");
-        Connection connection = factory.newConnection();
-        Channel channel = connection.createChannel();
-
-        channel.queueDeclare(queueName, false, false, false, null);
-        System.out.println(" [*] Waiting for messages...");
-
-        QueueingConsumer consumer = new QueueingConsumer(channel);
-        channel.basicConsume(queueName, true, consumer);
-
-        while (true) {
-            QueueingConsumer.Delivery delivery = consumer.nextDelivery();
-            String message = new String(delivery.getBody());
-            System.out.println(" [x] Received '" + message + "'");
-        }
-    }
-}

whatsmars-mq/whatsmars-mq-rabbitmq/src/main/java/org/hongxi/whatsmars/rabbitmq/Producer.java

-package org.hongxi.whatsmars.rabbitmq;
-
-import com.rabbitmq.client.Channel;
-import com.rabbitmq.client.Connection;
-import com.rabbitmq.client.ConnectionFactory;
-
-/**
- * Created by shenhongxi on 2017/9/8.
- */
-public class Producer {
-
-    public static void main(String[] args) throws Exception {
-        String queueName = "TestQueue";
-        ConnectionFactory factory = new ConnectionFactory();
-        factory.setHost("127.0.0.1");
-        Connection connection = factory.newConnection();
-        Channel channel = connection.createChannel();
-
-        channel.queueDeclare(queueName, false, false, false, null);
-        String message = "Hello World!";
-        channel.basicPublish("", queueName, null, message.getBytes());
-        System.out.println(" [x] Sent '" + message + "'");
-
-        channel.close();
-        connection.close();
-    }
-}

whatsmars-spring-boot/pom.xml

@@ -81,6 +81,11 @@
             <artifactId>gson</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>javax.servlet</groupId>
+            <artifactId>javax.servlet-api</artifactId>
+        </dependency>
+
         <dependency>
             <groupId>org.hongxi</groupId>
             <artifactId>whatsmars-common</artifactId>