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

yzg-util-mq/src/main/java/com/yanzuoguang/mq/vo/req/ServerMessageReqVo.java

@@ -10,6 +10,7 @@ import java.util.Map;
  * 发送给指定服务器消息
  *
  * @param <T>
+ * @author 颜佐光
  */
 public class ServerMessageReqVo<T> extends ServerQueueReqVo {
 
@@ -40,7 +41,7 @@ public class ServerMessageReqVo<T> extends ServerQueueReqVo {
     /**
      * 最大次数，达到最大次数时，会停止重发
      */
-    @ApiModelProperty(notes = "最大次数，达到最大次数时，会停止重发。为0时会一直重发")
+    @ApiModelProperty(notes = "最大次数，达到最大次数时，会停止重发。为0时，则默认为100")
     private int maxPos = 0;
 
     /**
@@ -110,7 +111,10 @@ public class ServerMessageReqVo<T> extends ServerQueueReqVo {
      * @return
      */
     public boolean isNext() {
-        return this.pos < this.maxPos || this.maxPos < 1;
+        if (this.maxPos == 0) {
+            this.maxPos = 100;
+        }
+        return this.pos < this.maxPos;
     }
 
     /**
@@ -130,7 +134,7 @@ public class ServerMessageReqVo<T> extends ServerQueueReqVo {
                 }
             }
         }
-        return max == null ? 600000: max.getValue();
+        return max == null ? 600000 : max.getValue();
     }
 
     public String getToken() {