From a37574a188a4f965d1d5dc498a54b1c4883ecf0f Mon Sep 17 00:00:00 2001
From: xiangwb <xiangwb@drore.com>
Date: Fri, 27 Apr 2018 17:52:37 +0800
Subject: [PATCH] merge

---
 .../src/main/java/com/xwbing/rabbit/Receiver.java    |  4 ++--
 .../src/main/java/com/xwbing/rabbit/Sender.java      | 12 +++++++++++-
 2 files changed, 13 insertions(+), 3 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 0cec0c3..5c965d9 100644
--- a/boot-service/src/main/java/com/xwbing/rabbit/Receiver.java
+++ b/boot-service/src/main/java/com/xwbing/rabbit/Receiver.java
@@ -21,7 +21,7 @@ public class Receiver {
     private final Logger logger = LoggerFactory.getLogger(Receiver.class);
 
     /**
-     * 处理消息并响应消息
+     * 处理server队列信息
      *
      * @param msg
      * @return
@@ -33,7 +33,7 @@ public class Receiver {
     }
 
     /**
-     * 处理消息
+     * 处理http队列消息
      *
      * @param 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 14ef52c..34bcf7e 100644
--- a/boot-service/src/main/java/com/xwbing/rabbit/Sender.java
+++ b/boot-service/src/main/java/com/xwbing/rabbit/Sender.java
@@ -44,7 +44,7 @@ public class Sender implements RabbitTemplate.ConfirmCallback, RabbitTemplate.Re
     }
 
     /**
-     * 无相应队列与交换器绑定异步回调
+     * 无相应队列与交换机绑定异步回调
      */
     @Override
     public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
@@ -52,10 +52,20 @@ public class Sender implements RabbitTemplate.ConfirmCallback, RabbitTemplate.Re
         logger.info("消息发送失败:{}", msg);
     }
 
+    /**
+     * 发送信息到server队列
+     *
+     * @param msg
+     */
     public void sendServerInvoke(String msg) {
         send(msg, RabbitConstant.CONTROL_EXCHANGE, RabbitConstant.SERVER_INVOKE_ROUTING_KEY);
     }
 
+    /**
+     * 发送信息到http队列
+     *
+     * @param msg
+     */
     public void sendHttpRequest(String msg) {
         send(msg, RabbitConstant.CONTROL_EXCHANGE, RabbitConstant.HTTP_REQUEST_ROUTING_KEY);
     }