提交 8d167988 编写于 作者: F faicm 提交者: Heng Du

Update DLedgerCommitLog.java (#1145)

Delete useless code
上级 2ea1ca68
...@@ -289,7 +289,6 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul ...@@ -289,7 +289,6 @@ DefaultMQProducer、TransactionMQProducer、DefaultMQPushConsumer、DefaultMQPul
| offsetStore | | 消费进度存储 | | offsetStore | | 消费进度存储 |
| consumeThreadMin | 10 | 消费线程池最小线程数 | | consumeThreadMin | 10 | 消费线程池最小线程数 |
| consumeThreadMax | 20 | 消费线程池最大线程数 | | consumeThreadMax | 20 | 消费线程池最大线程数 |
| | | |
| consumeConcurrentlyMaxSpan | 2000 | 单队列并行消费允许的最大跨度 | | consumeConcurrentlyMaxSpan | 2000 | 单队列并行消费允许的最大跨度 |
| pullThresholdForQueue | 1000 | 拉消息本地队列缓存消息最大数 | | pullThresholdForQueue | 1000 | 拉消息本地队列缓存消息最大数 |
| pullInterval | 0 | 拉消息间隔,由于是长轮询,所以为0,但是如果应用为了流控,也可以设置大于0的值,单位毫秒 | | pullInterval | 0 | 拉消息间隔,由于是长轮询,所以为0,但是如果应用为了流控,也可以设置大于0的值,单位毫秒 |
......
...@@ -99,12 +99,7 @@ public class DLedgerCommitLog extends CommitLog { ...@@ -99,12 +99,7 @@ public class DLedgerCommitLog extends CommitLog {
@Override @Override
public boolean load() { public boolean load() {
boolean result = super.load(); return super.load();
if (!result) {
return false;
}
return true;
} }
private void refreshConfig() { private void refreshConfig() {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册