anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修正聊天室错误

Browse Source
This commit is contained in:
heavyrain.lee
2020-01-11 11:06:17 +08:00
parent 2e4cf566c7
commit 5d9196939f
1 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+8
View File
@@ -597,6 +597,14 @@ public class MemoryMessagesStore implements IMessagesStore {
MemorySessionStore.Session session = m_Server.getStore().sessionsStore().getSession(clientId); MemorySessionStore.Session session = m_Server.getStore().sessionsStore().getSession(clientId);
String existChatroomId = (String)m_Server.getHazelcastInstance().getMap(USER_CHATROOM).get(user); String existChatroomId = (String)m_Server.getHazelcastInstance().getMap(USER_CHATROOM).get(user);
if (chatroomId == null) {
if (existChatroomId == null) {
return false;
} else {
chatroomId = existChatroomId;
}
}
if (StringUtil.isNullOrEmpty(existChatroomId) || !existChatroomId.equals(chatroomId)) { if (StringUtil.isNullOrEmpty(existChatroomId) || !existChatroomId.equals(chatroomId)) {
if (mChatroomRejoinWhenActive) { if (mChatroomRejoinWhenActive) {
if (!StringUtil.isNullOrEmpty(existChatroomId)) { if (!StringUtil.isNullOrEmpty(existChatroomId)) {