From 5ef8868916b6b086880e39aaf33f3983f84f807b Mon Sep 17 00:00:00 2001 From: "heavyrain.lee" Date: Wed, 19 Jun 2019 14:17:52 +0800 Subject: [PATCH] =?UTF-8?q?=E6=8E=A5=E5=8F=97=E6=96=B0=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E9=80=9A=E7=9F=A5=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/persistence/MemoryMessagesStore.java | 2 +- .../src/main/java/io/moquette/spi/impl/MessagesPublisher.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 00cb835c..b128f1a4 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1871,7 +1871,7 @@ public class MemoryMessagesStore implements IMessagesStore { if (entry.getScope() == request.getScope() && entry.getKey().equals(request.getKey())) { userSettingMap.remove(userId, entry); userSettingMap.put(userId, settingEntry); - return updateDt; + break; } } diff --git a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java index c8c445ba..35c9dc35 100755 --- a/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java +++ b/broker/src/main/java/io/moquette/spi/impl/MessagesPublisher.java @@ -308,7 +308,7 @@ public class MessagesPublisher { } if (isSlient) { - LOG.info("The conversation is slient"); + LOG.info("Slient of user or conversation"); continue; }