From b2be0bfdd4fe74dff8b3333690c6aeba03b6a7fa Mon Sep 17 00:00:00 2001 From: heavyrain2012 Date: Thu, 9 Dec 2021 19:40:30 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BD=93=E7=94=A8=E6=88=B7=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E6=9B=B4=E6=96=B0=E6=97=B6=E9=80=9A=E7=9F=A5=E5=85=B6=E4=BB=96?= =?UTF-8?q?=E7=AB=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 4 +++- broker/src/main/java/win/liyufan/im/IMTopic.java | 1 + 2 files changed, 4 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 2b735f3a..7841ec31 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -2223,7 +2223,6 @@ public class MemoryMessagesStore implements IMessagesStore { HazelcastInstance hzInstance = m_Server.getHazelcastInstance(); IMap mUserMap = hzInstance.getMap(USERS); - WFCMessage.User user = mUserMap.get(userId); if (user == null) { user = databaseStore.getPersistUser(userId); @@ -2287,6 +2286,7 @@ public class MemoryMessagesStore implements IMessagesStore { databaseStore.updateUser(user); mUserMap.set(userId, user); + IMHandler.getPublisher().publishNotification(IMTopic.NotifyUserInfoTopic, user.getUid(), 0, null); callbackUserInfoEvent(user); return ErrorCode.ERROR_CODE_SUCCESS; @@ -2434,6 +2434,8 @@ public class MemoryMessagesStore implements IMessagesStore { return ErrorCode.ERROR_CODE_SERVER_ERROR; } + IMHandler.getPublisher().publishNotification(IMTopic.NotifyUserInfoTopic, user.getUid(), 0, null); + mUserMap.put(user.getUid(), user); callbackUserInfoEvent(user); return ErrorCode.ERROR_CODE_SUCCESS; diff --git a/broker/src/main/java/win/liyufan/im/IMTopic.java b/broker/src/main/java/win/liyufan/im/IMTopic.java index 69ac7d4d..d64316a9 100755 --- a/broker/src/main/java/win/liyufan/im/IMTopic.java +++ b/broker/src/main/java/win/liyufan/im/IMTopic.java @@ -40,6 +40,7 @@ public interface IMTopic { String GetUserInfoTopic = "UPUI"; String ModifyMyInfoTopic = "MMI"; + String NotifyUserInfoTopic = "UIN"; String GetQiniuUploadTokenTopic = "GQNUT";