接口文档的支持

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

@@ -177,7 +177,7 @@ public class MqServiceImpl implements MqService {
     /**
      * 建立当前服务器的队列
      *
-     * @param req      请求数据
+     * @param req 请求数据
      * @return
      */
     @Override
@@ -254,7 +254,9 @@ public class MqServiceImpl implements MqService {
         } else {
             queueServerTokenDao.update(serverTokenVo);
         }
-        yzgMqConsumer.sendRemove(req);
+        if (req.getFairTime() > 0) {
+            yzgMqConsumer.sendRemove(req);
+        }
         return serverTokenVo.getServerTokenId();
     }