diff --git a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java index 69302033..aa864ebc 100755 --- a/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java +++ b/broker/src/main/java/io/moquette/persistence/MemoryMessagesStore.java @@ -1870,7 +1870,7 @@ public class MemoryMessagesStore implements IMessagesStore { } if (existRequest != null && existRequest.getStatus() != ProtoConstants.FriendRequestStatus.RequestStatus_Accepted) { - if (System.currentTimeMillis() - existRequest.getUpdateDt() > mFriendRequestDuration) { + if (mFriendRequestDuration > 0 && System.currentTimeMillis() - existRequest.getUpdateDt() > mFriendRequestDuration) { if (existRequest.getStatus() == ProtoConstants.FriendRequestStatus.RequestStatus_Rejected && System.currentTimeMillis() - existRequest.getUpdateDt() < mFriendRejectDuration) { return ErrorCode.ERROR_CODE_FRIEND_REQUEST_BLOCKED; @@ -2004,7 +2004,7 @@ public class MemoryMessagesStore implements IMessagesStore { } if (existRequest != null) { - if (System.currentTimeMillis() - existRequest.getUpdateDt() > mFriendRequestDuration) { + if (mFriendRequestDuration > 0 && System.currentTimeMillis() - existRequest.getUpdateDt() > mFriendRequestDuration) { return ErrorCode.ERROR_CODE_FRIEND_REQUEST_OVERTIME; } else { existRequest = existRequest.toBuilder().setStatus(ProtoConstants.FriendRequestStatus.RequestStatus_Accepted).setUpdateDt(System.currentTimeMillis()).build();