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); } }