From 92c3c985536c9cf49a0e1772acadd3c6bfb85060 Mon Sep 17 00:00:00 2001 From: heavyrian2012 Date: Fri, 29 Sep 2023 10:32:52 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A7=A3=E5=86=B3=E9=87=8D=E5=A4=8D=E5=8F=91?= =?UTF-8?q?=E9=80=81=E5=A5=BD=E5=8F=8B=E8=AF=B7=E6=B1=82=E6=97=B6=EF=BC=8C?= =?UTF-8?q?=E8=AF=B7=E6=B1=82=E6=97=B6=E9=97=B4=E6=B2=A1=E6=9C=89=E6=9B=B4?= =?UTF-8?q?=E6=96=B0=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/io/moquette/persistence/MemoryMessagesStore.java | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 7b6d9478..87ae2929 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -3111,9 +3111,7 @@ public class MemoryMessagesStore implements IMessagesStore { } } - boolean alreadyExist = false; if (existRequest != null && existRequest.getStatus() != ProtoConstants.FriendRequestStatus.RequestStatus_Accepted && !isAdmin) { - alreadyExist = true; if (mFriendRequestDuration > 0 && System.currentTimeMillis() - existRequest.getUpdateDt() > mFriendRequestDuration) { if (existRequest.getStatus() == ProtoConstants.FriendRequestStatus.RequestStatus_Rejected && System.currentTimeMillis() - existRequest.getUpdateDt() < mFriendRejectDuration) { @@ -3144,7 +3142,7 @@ public class MemoryMessagesStore implements IMessagesStore { .setExtra(request.getExtra()) .setStatus(ProtoConstants.FriendRequestStatus.RequestStatus_Sent) .setToReadStatus(false) - .setUpdateDt(alreadyExist ? existRequest.getUpdateDt() : System.currentTimeMillis()) + .setUpdateDt(System.currentTimeMillis()) .build(); databaseStore.persistOrUpdateFriendRequest(newRequest);