..

Wizzercn · Jul 31, 2018 · 0e9ee44 · 0e9ee44
1 parent 3ec187b
commit 0e9ee44
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/mqtt-store/src/main/java/cn/wizzer/iot/mqtt/server/store/message/MessageIdService.java b/mqtt-store/src/main/java/cn/wizzer/iot/mqtt/server/store/message/MessageIdService.java
@@ -19,7 +19,9 @@ public class MessageIdService implements IMessageIdService {
     @Override
     public int getNextMessageId() {
         try {
-            nextMsgId = (int) (redisService.incr("mqttwk:messageid:num") % 65535);
+            nextMsgId = (int) (redisService.incr("mqttwk:messageid:num") % 65536);
+            if (nextMsgId == 0)
+                return this.getNextMessageId();
         } catch (Exception e) {
             e.printStackTrace();
         }