You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2019/07/24 11:37:54 UTC
[rocketmq] branch develop updated: Update DLedgerCommitLog.java
(#1145)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 8d16798 Update DLedgerCommitLog.java (#1145)
8d16798 is described below
commit 8d16798823cae8bca02870751974aa272fc21c5f
Author: faicm <op...@outlook.com>
AuthorDate: Wed Jul 24 19:37:43 2019 +0800
Update DLedgerCommitLog.java (#1145)
Delete useless code
---
docs/cn/best_practice.md | 1 -
.../java/org/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 39febbc..e4b04e0 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 17be11b..5192e86 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() {