From 3d50b65ad973fd28221f66416027e16df2f327ff Mon Sep 17 00:00:00 2001
From: "heavyrain.lee" <heavyrain.lee@gmail.com>
Date: Mon, 20 May 2019 19:34:49 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E6=95=8F=E6=84=9F=E8=AF=8D?=
 =?UTF-8?q?=E8=AE=BE=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../io/moquette/persistence/MemoryMessagesStore.java     | 9 ++++++++-
 1 file changed, 8 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 d4740624..208ab372 100755
--- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
@@ -138,7 +138,13 @@ public class MemoryMessagesStore implements IMessagesStore {
     private void updateSensitiveWord() {
         long now = System.currentTimeMillis();
         if (now - lastUpdateSensitiveTime > 2 * 60 * 60 * 1000) {
-            lastUpdateSensitiveTime = now;
+            synchronized (this) {
+                if (now - lastUpdateSensitiveTime > 2 * 60 * 60 * 1000) {
+                    lastUpdateSensitiveTime = now;
+                } else {
+                    return;
+                }
+            }
             Set<String> sensitiveWords = databaseStore.getSensitiveWord();
             mSensitiveFilter = new SensitiveFilter(sensitiveWords);
         }
@@ -2027,6 +2033,7 @@ public class MemoryMessagesStore implements IMessagesStore {
             words) {
             databaseStore.persistSensitiveWord(word);
         }
+        lastUpdateSensitiveTime = 0;
         return true;
     }