From ace676d215374ec06c0b77f0c14768811d5e77c2 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Sat, 29 Jan 2022 13:47:34 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E6=8E=A5=E5=8F=97=E5=A5=BD?= =?UTF-8?q?=E5=8F=8B=E5=90=8E=E9=80=9A=E7=9F=A5=E5=85=B6=E4=BB=96=E7=AB=AF?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/io/moquette/persistence/MemoryMessagesStore.java | 2 +- 1 file changed, 1 insertion(+), 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 f2b6433a..6fe0d8ff 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -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); } }