From a2ee6c87eb2a30ef3903350624af8b96b51002ef Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Wed, 6 Sep 2023 15:20:38 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=8D=E8=83=BD=E6=8A=8A=E7=BE=A4=E4=B8=BB?= =?UTF-8?q?=E8=AE=BE=E7=BD=AE=E4=B8=BA=E7=AE=A1=E7=90=86=E5=91=98?= 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 c7dc3025..697fae2b 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2074,6 +2074,10 @@ public class MemoryMessagesStore implements IMessagesStore { return ErrorCode.ERROR_CODE_NOT_RIGHT; } + if(userList.contains(groupInfo.getOwner())) { + return ErrorCode.ERROR_CODE_NOT_RIGHT; + } + long updateDt = System.currentTimeMillis(); MultiMap groupMembers = hzInstance.getMultiMap(GROUP_MEMBERS); Collection members = groupMembers.get(groupId);