From 4f27d492a1d859afd1dc3313ac049eb72214f23c Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Wed, 19 Feb 2020 17:20:46 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E9=A2=91=E9=81=93=E9=83=A8?= =?UTF-8?q?=E5=88=86=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/imhandler/CreateChannelHandler.java | 2 +- .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/broker/src/main/java/io/moquette/imhandler/CreateChannelHandler.java b/broker/src/main/java/io/moquette/imhandler/CreateChannelHandler.java index f619a40f..bcc7d937 100644 --- a/broker/src/main/java/io/moquette/imhandler/CreateChannelHandler.java +++ b/broker/src/main/java/io/moquette/imhandler/CreateChannelHandler.java @@ -41,7 +41,7 @@ public class CreateChannelHandler extends GroupHandler { if (errorCode == ErrorCode.ERROR_CODE_SUCCESS) { WFCMessage.ModifyUserSettingReq modifyUserSettingReq = WFCMessage.ModifyUserSettingReq.newBuilder().setScope(kUserSettingMyChannels).setKey(request.getTargetId()).setValue("1").build(); mServer.internalRpcMsg(fromUser, null, modifyUserSettingReq.toByteArray(), 0, fromUser, PutUserSettingTopic, false); - byte[] data = request.getSecret().getBytes(); + byte[] data = request.getTargetId().getBytes(); ackPayload.ensureWritable(data.length).writeBytes(data); return ErrorCode.ERROR_CODE_SUCCESS; } else { diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 2c00cd2a..94f8071c 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -306,7 +306,7 @@ public class MemoryMessagesStore implements IMessagesStore { notifyReceivers.add(fromUser); if (channelInfo.getOwner().equals(fromUser)) { MultiMap listeners = hzInstance.getMultiMap(CHANNEL_LISTENERS); - if (StringUtil.isNullOrEmpty(message.getToUser())) { + if (!StringUtil.isNullOrEmpty(message.getToUser())) { if (listeners.values().contains(message.getToUser())) { notifyReceivers.add(message.getToUser()); }