From 43892dbe41d0cf19885259c0a8a5380be092fce5 Mon Sep 17 00:00:00 2001
From: heavyrian2012 <heavyrain.lee@wildfirehat.cn>
Date: Thu, 2 Mar 2023 08:52:43 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E5=85=B3=E9=97=ADroaming?=
 =?UTF-8?q?=EF=BC=8C=E4=B8=94message.compensate=5Ftime=5Flimit=E9=85=8D?=
 =?UTF-8?q?=E7=BD=AE=E4=B8=BA-1=E6=97=B6=EF=BC=8C=E9=A6=96=E6=AC=A1?=
 =?UTF-8?q?=E6=B6=88=E6=81=AF=E6=97=A0=E6=B3=95=E5=90=8C=E6=AD=A5=E7=9A=84?=
 =?UTF-8?q?=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/io/moquette/persistence/MemoryMessagesStore.java   | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
index 78f3e491..c53a3525 100755
--- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
@@ -847,6 +847,10 @@ public class MemoryMessagesStore implements IMessagesStore {
             mReadLock.unlock();
         }
 
+        if(current == 0) {
+            current = 2;
+            head = 2;
+        }
         builder.setCurrent(current);
         builder.setHead(head);
         return builder.build();
@@ -1000,7 +1004,7 @@ public class MemoryMessagesStore implements IMessagesStore {
                 messageSeq = maxPullSeq + 1;
             }
 
-            if (messageSeq == 0) {
+            if (messageSeq < messageId) {
                 messageSeq = messageId;
             }