设置打包时可以通过ＧＩＴ查看源码

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

@@ -302,8 +302,11 @@ public class MqServiceImpl implements MqService {
     @ApiOperation(value = "发送给指定服务器消息")
     @Override
     public String sendServerMessage(ServerMessageReqVo req) {
+        // 发送消息，等待下次重新发送
+        req.addPos();
         if (!req.isNext()) {
-            throw new CodeException("达到最大次数,不会继续发送");
+            Log.error(MqServiceImpl.class, "达到最大次数,不会继续发送");
+            return StringHelper.EMPTY;
         }
 
         String queueName = req.getQueueName();
@@ -333,11 +336,6 @@ public class MqServiceImpl implements MqService {
             Log.error(MqServiceImpl.class, ex);
         }
 
-        // 发送消息，等待下次重新发送
-        req.addPos();
-        if (!req.isNext()) {
-            throw new CodeException("达到最大次数,不会继续发送");
-        }
         if (sendQueueName.isEmpty()) {
             String json = JsonHelper.serialize(req);
             return this.message(new MessageVo(req.getQueueName(), req.getQueueName(), json, req.getNextDelayTime()));