diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 1b9955ec..53d9bb04 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1047,7 +1047,7 @@ public class MemoryMessagesStore implements IMessagesStore { return ErrorCode.ERROR_CODE_GROUP_MUTED; } - if (member.getMemberId().equals(memberId) && member.getType() != GroupMemberType_Removed) { + if (member.getMemberId().equals(memberId) && member.getType() == GroupMemberType_Removed) { return ErrorCode.ERROR_CODE_NOT_IN_GROUP; } }