From c82869c631e64730a43b3d3f17bf9c367b360c85 Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Wed, 10 Jul 2019 15:08:10 +0800 Subject: [PATCH] =?UTF-8?q?=E7=BE=A4=E4=B8=BB=E5=8F=AF=E4=BB=A5=E5=9C=A8?= =?UTF-8?q?=E7=BE=A4=E7=A6=81=E8=A8=80=E6=97=B6=E5=8F=91=E4=BF=A1=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 4 ++++ 1 file changed, 4 insertions(+) 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; } }