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()); } }