From 8d16798823cae8bca02870751974aa272fc21c5f Mon Sep 17 00:00:00 2001 From: faicm Date: Wed, 24 Jul 2019 19:37:43 +0800 Subject: [PATCH] Update DLedgerCommitLog.java (#1145) Delete useless code --- docs/cn/best_practice.md | 1 - .../apache/rocketmq/store/dledger/DLedgerCommitLog.java | 7 +------ 2 files changed, 1 insertion(+), 7 deletions(-) diff --git a/docs/cn/best_practice.md b/docs/cn/best_practice.md index 39febbcd..e4b04e0d 100755 --- a/docs/cn/best_practice.md +++ b/docs/cn/best_practice.md @@ -289,7 +289,6 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul | offsetStore | | 消费进度存储 | | consumeThreadMin | 10 | 消费线程池最小线程数 | | consumeThreadMax | 20 | 消费线程池最大线程数 | -| | | | | consumeConcurrentlyMaxSpan | 2000 | 单队列并行消费允许的最大跨度 | | pullThresholdForQueue | 1000 | 拉消息本地队列缓存消息最大数 | | pullInterval | 0 | 拉消息间隔，由于是长轮询，所以为0，但是如果应用为了流控，也可以设置大于0的值，单位毫秒 | diff --git a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java index 17be11b1..5192e86d 100644 --- a/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java +++ b/store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java @@ -99,12 +99,7 @@ public class DLedgerCommitLog extends CommitLog { @Override public boolean load() { - boolean result = super.load(); - if (!result) { - return false; - } - - return true; + return super.load(); } private void refreshConfig() { -- GitLab