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:
imhao183
2020-11-11 13:08:28 +08:00
parent 7f6b2d93df
commit 3438de39ad
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+6 -6
View File
@@ -368,9 +368,9 @@ public class MemoryMessagesStore implements IMessagesStore {
pullType = ProtoConstants.PullType.Pull_ChatRoom; pullType = ProtoConstants.PullType.Pull_ChatRoom;
} }
if (message.getContent().getPersistFlag() != Transparent) { // if (message.getContent().getPersistFlag() != Transparent) {
notifyReceivers.add(fromUser); notifyReceivers.add(fromUser);
} // }
return pullType; return pullType;
} }
@@ -454,10 +454,10 @@ public class MemoryMessagesStore implements IMessagesStore {
LOG.error("Channel not exist"); LOG.error("Channel not exist");
} }
} }
//
if (message.getContent().getPersistFlag() == Transparent) { // if (message.getContent().getPersistFlag() == Transparent) {
notifyReceivers.remove(fromUser); // notifyReceivers.remove(fromUser);
} // }
return pullType; return pullType;
} }