From 1d234a357510e2f0381c8a232c11e797f6c9d407 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Sun, 28 Apr 2024 17:11:36 +0800 Subject: [PATCH] =?UTF-8?q?=E8=8E=B7=E5=8F=96=E8=A2=AB=E5=88=A0=E9=99=A4?= =?UTF-8?q?=E7=BE=A4=E7=BB=84=E6=97=B6=E6=80=BB=E6=98=AF=E5=90=8C=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 2 +- 1 file changed, 1 insertion(+), 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 f837465f..d6b112ca 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2099,7 +2099,7 @@ public class MemoryMessagesStore implements IMessagesStore { for (WFCMessage.UserRequest request : requests) { WFCMessage.GroupInfo groupInfo = mIMap.get(request.getUid()); if (groupInfo != null && groupInfo.getUpdateDt() > request.getUpdateDt()) { - if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser)) { + if(!isAdmin && !StringUtil.isNullOrEmpty(fromUser) && groupInfo.getDeleted() == 0) { WFCMessage.GroupMember gm = getGroupMember(groupInfo.getTargetId(), fromUser); if((gm == null || gm.getType() == GroupMemberType_Removed) && request.getUpdateDt() > 0) { continue;