diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index b1fc8e9f..cb8f3422 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -922,7 +922,7 @@ public class MemoryMessagesStore implements IMessagesStore { .setExtra(groupInfo.getExtra()) .setUpdateDt(dt) .setMemberUpdateDt(dt) - .setMemberCount(memberList.size()) + .setMemberCount(updatedMemberList.size()) .setOwner(owner) .build();