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:
heavyrian2012
2022-01-29 13:47:34 +08:00
parent 1170c4209b
commit ace676d215
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java
+1 -1
View File
@@ -3034,6 +3034,7 @@ public class MemoryMessagesStore implements IMessagesStore {
} else {
existRequest = existRequest.toBuilder().setStatus(request.getStatus()).setUpdateDt(System.currentTimeMillis()).build();
heads[2] = existRequest.getUpdateDt();
heads[3] = existRequest.getUpdateDt();
databaseStore.persistOrUpdateFriendRequest(existRequest);
if (request.getStatus() == ProtoConstants.FriendRequestStatus.RequestStatus_Accepted) {
@@ -3052,7 +3053,6 @@ public class MemoryMessagesStore implements IMessagesStore {
if (existTargetRequest != null && existTargetRequest.getStatus() == ProtoConstants.FriendRequestStatus.RequestStatus_Sent) {
existTargetRequest = existTargetRequest.toBuilder().setStatus(request.getStatus()).setUpdateDt(existRequest.getUpdateDt()).build();
heads[3] = existRequest.getUpdateDt();
databaseStore.persistOrUpdateFriendRequest(existTargetRequest);
}
}