From 613e2d8a9bf81ee74252e25a30dcfff36d03114b Mon Sep 17 00:00:00 2001
From: xiangwb <xiangwb@drore.com>
Date: Wed, 25 Apr 2018 16:24:02 +0800
Subject: [PATCH] merge

---
 .../src/main/java/com/xwbing/Rabbit/Receiver.java   | 13 ++++++++++++-
 .../src/main/java/com/xwbing/Rabbit/Sender.java     |  2 +-
 2 files changed, 13 insertions(+), 2 deletions(-)

diff --git a/boot-service/src/main/java/com/xwbing/Rabbit/Receiver.java b/boot-service/src/main/java/com/xwbing/Rabbit/Receiver.java
index 64296d0..48cd3c9 100644
--- a/boot-service/src/main/java/com/xwbing/Rabbit/Receiver.java
+++ b/boot-service/src/main/java/com/xwbing/Rabbit/Receiver.java
@@ -12,18 +12,29 @@ import static com.xwbing.Rabbit.RabbitConstant.SERVER_INVOKE_QUEUE;
  * 项目名称: boot-module-demo
  * 创建时间: 2018/4/25 15:12
  * 作者: xiangwb
- * 说明:
+ * 说明: 消费者
  */
 @Component
 public class Receiver {
     private final Logger logger = LoggerFactory.getLogger(Receiver.class);
 
+    /**
+     * 处理消息并响应消息
+     *
+     * @param msg
+     * @return
+     */
     @RabbitListener(queues = SERVER_INVOKE_QUEUE)
     public String processServer(String msg) {
         logger.info("接收到来自{}队列的消息:{}", SERVER_INVOKE_QUEUE, msg);
         return msg.toUpperCase();
     }
 
+    /**
+     * 处理消息
+     *
+     * @param msg
+     */
     @RabbitListener(queues = HTTP_REQUEST_QUEUE)
     public void processHttp(String msg) {
         logger.info("接收到来自{}队列的消息:{}", HTTP_REQUEST_QUEUE, msg);
diff --git a/boot-service/src/main/java/com/xwbing/Rabbit/Sender.java b/boot-service/src/main/java/com/xwbing/Rabbit/Sender.java
index 7ff1f39..477d521 100644
--- a/boot-service/src/main/java/com/xwbing/Rabbit/Sender.java
+++ b/boot-service/src/main/java/com/xwbing/Rabbit/Sender.java
@@ -15,7 +15,7 @@ import java.util.UUID;
  * 项目名称: boot-module-demo
  * 创建时间: 2018/4/25 14:48
  * 作者: xiangwb
- * 说明:
+ * 说明: 生产者
  */
 @Component
 public class Sender implements RabbitTemplate.ConfirmCallback, RabbitTemplate.ReturnCallback {