From 3ab1c7553db6d9c846df1f7f91a2493615aed38e Mon Sep 17 00:00:00 2001
From: heavyrian2012 <heavyrain.lee@wildfirehat.cn>
Date: Thu, 25 Apr 2024 10:45:21 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A6=82=E6=9E=9C=E7=94=A8=E6=88=B7=E4=B8=8D?=
 =?UTF-8?q?=E5=9C=A8=E7=BE=A4=E4=B8=AD=EF=BC=8C=E4=B8=8D=E5=86=8D=E8=BF=9B?=
 =?UTF-8?q?=E8=A1=8C=E7=BE=A4=E7=BB=84=E4=BF=A1=E6=81=AF=E6=9B=B4=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
index 601fa86f..f837465f 100755
--- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
@@ -2101,6 +2101,9 @@ public class MemoryMessagesStore implements IMessagesStore {
             if (groupInfo != null && groupInfo.getUpdateDt() > request.getUpdateDt()) {
                 if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser)) {
                     WFCMessage.GroupMember gm = getGroupMember(groupInfo.getTargetId(), fromUser);
+                    if((gm == null || gm.getType() == GroupMemberType_Removed) && request.getUpdateDt() > 0) {
+                        continue;
+                    }
                     if(gm == null) {
                         groupInfo = groupInfo.toBuilder().setMemberUpdateDt(-1).build();
                     } else if(gm.getType() == GroupMemberType_Removed) {