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

fix error

Browse Source
This commit is contained in:
heavyrian2012
2025-09-06 23:33:35 +08:00
parent fe15a32499
commit 804c12845e
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+2 -2
View File
@@ -745,8 +745,8 @@ public class MemoryMessagesStore implements IMessagesStore {
int type = message.getConversation().getType(); int type = message.getConversation().getType();
int pullType = ProtoConstants.PullType.Pull_Normal; int pullType = ProtoConstants.PullType.Pull_Normal;
if (mRobotMentionExternalRobot && type == ProtoConstants.ConversationType.ConversationType_Private) { if (type == ProtoConstants.ConversationType.ConversationType_Private) {
if(message.getConversation().getTarget().contains("|")) { if(mRobotMentionExternalRobot && message.getConversation().getTarget().contains("|")) {
String[] ss = message.getConversation().getTarget().split("\\|"); String[] ss = message.getConversation().getTarget().split("\\|");
notifyReceivers.add(ss[0]); notifyReceivers.add(ss[0]);
notifyReceivers.add(ss[1]); notifyReceivers.add(ss[1]);