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() {

Reply via email to