diff --git a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java index 59ef49045a20f5f032aefdbed0a436574abb1620..192d0972e6440428914b9ce580848575f19d26e8 100644 --- a/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java +++ b/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java @@ -416,12 +416,8 @@ public class DefaultMessageStore implements MessageStore { long begin = this.getCommitLog().getBeginTimeInLock(); long diff = this.systemClock.now() - begin; - if (diff < 10000000 - && diff > this.messageStoreConfig.getOsPageCacheBusyTimeOutMills()) { - return true; - } - - return false; + return diff < 10000000 + && diff > this.messageStoreConfig.getOsPageCacheBusyTimeOutMills(); } @Override