From 3438de39ad7ca976be44dfd33d9fd18a49d45f61 Mon Sep 17 00:00:00 2001 From: imhao183 Date: Wed, 11 Nov 2020 13:07:37 +0800 Subject: [PATCH] =?UTF-8?q?=E7=8A=B6=E6=80=81=E6=B6=88=E6=81=AF=E4=B9=9F?= =?UTF-8?q?=E9=9C=80=E8=A6=81=E5=90=8C=E6=AD=A5=E5=88=B0=E5=8F=91=E9=80=81?= =?UTF-8?q?=E8=80=85=E7=9A=84=E5=85=B6=E5=AE=83=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../io/moquette/persistence/MemoryMessagesStore.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 9a63e636..12af98b5 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -368,9 +368,9 @@ public class MemoryMessagesStore implements IMessagesStore { pullType = ProtoConstants.PullType.Pull_ChatRoom; } - if (message.getContent().getPersistFlag() != Transparent) { +// if (message.getContent().getPersistFlag() != Transparent) { notifyReceivers.add(fromUser); - } +// } return pullType; } @@ -454,10 +454,10 @@ public class MemoryMessagesStore implements IMessagesStore { LOG.error("Channel not exist"); } } - - if (message.getContent().getPersistFlag() == Transparent) { - notifyReceivers.remove(fromUser); - } +// +// if (message.getContent().getPersistFlag() == Transparent) { +// notifyReceivers.remove(fromUser); +// } return pullType; }