From fbe5bf7a773b3ed293243ab6e583a83bac5c2d6b Mon Sep 17 00:00:00 2001 From: imhao183 Date: Thu, 27 Aug 2020 18:20:07 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E9=80=80=E5=87=BA=E7=BE=A4?= =?UTF-8?q?=E7=BB=84=E5=90=8E=E6=88=90=E5=91=98=E8=8E=B7=E5=8F=96=E7=BE=A4?= =?UTF-8?q?=E7=BB=84=E6=88=90=E5=91=98=E9=94=99=E8=AF=AF=E9=97=AE=E9=A2=98?= 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 d3ab4341..0b82a4fe 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1283,7 +1283,7 @@ public class MemoryMessagesStore implements IMessagesStore { if (fromUser != null && notInGroup) { members.clear(); if (self != null) { - members.add(self.toBuilder().setUpdateDt(0).setType(GroupMemberType_Normal).build()); + members.add(self.toBuilder().setUpdateDt(0).setType(GroupMemberType_Removed).build()); } }