接口文档的支持

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

@@ -64,7 +64,6 @@ public interface MqService {
     void basicAck(Message message, Channel channel);
 
     /**
-     *
      * 删除当前服务器的队列
      *
      * @param req 请求数据
@@ -76,11 +75,20 @@ public interface MqService {
      * 建立当前服务器的队列
      *
      * @param req      请求数据
-     * @param listener 处理函数
      * @return
      */
     @ApiOperation(value = "建立当前服务器的队列")
-    String createServerQueue(ServerQueueReqVo req, ChannelAwareMessageListener listener);
+    String createServerQueue(ServerQueueReqVo req);
+
+    /**
+     * 注册当前消费队列的回调
+     *
+     * @param req      请求数据
+     * @param listener 处理函数
+     * @return
+     */
+    @ApiOperation(value = "注册当前消费队列的回调")
+    String setServerQueueConsumer(ServerQueueReqVo req, ChannelAwareMessageListener listener);
 
     /**
      * 注册当前服务器的token，超期后需要重新注册
@@ -93,6 +101,7 @@ public interface MqService {
 
     /**
      * 删除token的执行
+     *
      * @param req
      */
     @ApiOperation(value = "删除token的执行")

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

@@ -178,11 +178,10 @@ public class MqServiceImpl implements MqService {
      * 建立当前服务器的队列
      *
      * @param req      请求数据
-     * @param listener 处理函数
      * @return
      */
     @Override
-    public String createServerQueue(ServerQueueReqVo req, ChannelAwareMessageListener listener) {
+    public String createServerQueue(ServerQueueReqVo req) {
         String queueName = req.getQueueName();
         String localQueueName = this.getLocalName(req.getQueueName());
         String serverId = StringHelper.getMD5Id(localQueueName);
@@ -203,7 +202,6 @@ public class MqServiceImpl implements MqService {
                 }
             }
         });
-        this.mqConsumeDynamic.init(localQueueName, listener);
 
         QueueServerVo vo = new QueueServerVo();
         vo.setServerId(serverId);
@@ -214,6 +212,21 @@ public class MqServiceImpl implements MqService {
         return "创建成功";
     }
 
+    /**
+     * 注册当前消费队列的回调
+     *
+     * @param req      请求数据
+     * @param listener 处理函数
+     * @return
+     */
+    @Override
+    public String setServerQueueConsumer(ServerQueueReqVo req, ChannelAwareMessageListener listener) {
+        String queueName = req.getQueueName();
+        String localQueueName = this.getLocalName(req.getQueueName());
+        this.mqConsumeDynamic.init(localQueueName, listener);
+        return "注册成功";
+    }
+
     /**
      * 注册当前服务器的token，超期后需要重新注册
      *