From a646cc822794134374d6488b61cee7d576758cec Mon Sep 17 00:00:00 2001 From: heavyrain lee Date: Wed, 17 Jul 2019 00:36:17 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E6=8E=89=E5=90=AF=E5=8A=A8=E6=97=B6?= =?UTF-8?q?=E9=A2=84=E8=AF=BB=E6=95=B0=E6=8D=AE=EF=BC=8C=E5=8A=A0=E5=BF=AB?= =?UTF-8?q?=E5=90=AF=E5=8A=A8=E9=80=9F=E5=BA=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../io/moquette/persistence/MemoryMessagesStore.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index d993c715..99639476 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -61,7 +61,6 @@ import static win.liyufan.im.MyInfoType.*; public class MemoryMessagesStore implements IMessagesStore { private static final String MESSAGES_MAP = "messages_map"; private static final String GROUPS_MAP = "groups_map"; - private static final String GROUP_ID_COUNTER = "group_id_counter"; static int dumy = 0; static final String GROUP_MEMBERS = "group_members"; @@ -120,14 +119,6 @@ public class MemoryMessagesStore implements IMessagesStore { @Override public void initStore() { - //TODO reload data from mysql - HazelcastInstance hzInstance = m_Server.getHazelcastInstance(); - MultiMap groupMembers = hzInstance.getMultiMap(MemoryMessagesStore.GROUP_MEMBERS); - if (groupMembers.size() == 0) { - databaseStore.reloadFriendsFromDB(hzInstance); - databaseStore.reloadFriendRequestsFromDB(hzInstance); - } - updateSensitiveWord(); }