From 950846df456d0336f04ad39eabf803edc1b9a792 Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Tue, 9 Jul 2019 08:50:14 +0800 Subject: [PATCH] update --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 7d061440..87b5c878 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -647,7 +647,12 @@ public class MemoryMessagesStore implements IMessagesStore { } if (groupInfo.getType() == ProtoConstants.GroupType.GroupType_Restricted && ((groupInfo.getOwner() == null || !groupInfo.getOwner().equals(operator)) && !isManager)) { - return ErrorCode.ERROR_CODE_NOT_RIGHT; + if (groupInfo.getJoinType() == 2) { + return ErrorCode.ERROR_CODE_NOT_RIGHT; + } else if (groupInfo.getJoinType() == 1) { + if (memberList.size() == 1 && operator.equals(memberList.get(0).getMemberId())) + return ErrorCode.ERROR_CODE_NOT_RIGHT; + } } if (!isMember) {