升级新版本

yzg-util-mq/src/main/java/com/yanzuoguang/mq/service/MqService.java

@@ -68,8 +68,11 @@ public interface MqService {
     /**
      * 消息收到确认
      *
-     * @param message 收到的消息
+     * @param messageBody             消息体
      * @param channel                 　收到的通道
+     * @param exchangeNameAndRouteKey 　出错时重发的路由
+     * @param message                 　消息内容
+     * @param consumerMessage         消费者，具体业务处理函数
      */
     @ApiOperation(value = "消息收到确认")
     void basicHandle(Message messageBody, Channel channel, String exchangeNameAndRouteKey, String message, Consumer<String> consumerMessage);
@@ -78,8 +81,12 @@ public interface MqService {
     /**
      * 消息收到确认
      *
-     * @param message 收到的消息
+     * @param messageBody             消息体
      * @param channel                 　收到的通道
+     * @param exchangeNameAndRouteKey 　出错时重发的路由
+     * @param message                 　消息内容
+     * @param dedTime                 　消息延迟处理时间
+     * @param consumerMessage         消费者，具体业务处理函数
      */
     @ApiOperation(value = "消息收到确认")
     void basicHandle(Message messageBody, Channel channel, String exchangeNameAndRouteKey, String message, long dedTime, Consumer<String> consumerMessage);
@@ -87,8 +94,13 @@ public interface MqService {
     /**
      * 消息收到确认
      *
-     * @param message 收到的消息
+     * @param messageBody     消息体
      * @param channel         　收到的通道
+     * @param exchangeName    　出错时重发的交换器
+     * @param routeKey        　出错时重发的路由
+     * @param message         　消息内容
+     * @param dedTime         　消息延迟处理时间
+     * @param consumerMessage 消费者，具体业务处理函数
      */
     @ApiOperation(value = "消息收到确认")
     void basicHandle(Message messageBody, Channel channel, String exchangeName, String routeKey, String message, long dedTime, Consumer<String> consumerMessage);