diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 1168ed84..2355cebb 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1073,6 +1073,9 @@ public class MemoryMessagesStore implements IMessagesStore { WFCMessage.GroupInfo groupInfo = groups.get(groupId); boolean isMute = false; if (groupInfo != null) { + if (groupInfo.getOwner().equals(memberId)) { + return ErrorCode.ERROR_CODE_SUCCESS; + } isMute = groupInfo.getMute()>0; } @@ -1092,6 +1095,7 @@ public class MemoryMessagesStore implements IMessagesStore { if (member.getMemberId().equals(memberId) && member.getType() == GroupMemberType_Removed) { return ErrorCode.ERROR_CODE_NOT_IN_GROUP; } + break; } }