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 <[email protected]>
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() {