opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-19 02:23:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove enableBuildConsumeQueueConcurrently attribute from BrokerConfig class

Browse Source
This commit is contained in:
nowinkey
2023-02-14 13:50:47 +08:00
committed by Zhouxiang Zhan
parent dcf84e4125
commit c2ea0922b7
2 changed files with 2 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
-12
View File
@@ -401,10 +401,6 @@ public class BrokerConfig extends BrokerIdentity {
*/
private boolean estimateAccumulation = true;
/**
* Build ConsumeQueue concurrently with multi-thread
*/
private boolean enableBuildConsumeQueueConcurrently = false;
public long getMaxPopPollingSize() {
return maxPopPollingSize;
@@ -1661,12 +1657,4 @@ public class BrokerConfig extends BrokerIdentity {
public void setBatchDispatchRequestThreadPoolNums(int batchDispatchRequestThreadPoolNums) {
this.batchDispatchRequestThreadPoolNums = batchDispatchRequestThreadPoolNums;
}
public boolean isEnableBuildConsumeQueueConcurrently() {
return enableBuildConsumeQueueConcurrently;
}
public void setEnableBuildConsumeQueueConcurrently(boolean enableBuildConsumeQueueConcurrently) {
this.enableBuildConsumeQueueConcurrently = enableBuildConsumeQueueConcurrently;
}
}
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
+2 -2
View File
@@ -234,7 +234,7 @@ public class DefaultMessageStore implements MessageStore {
}
}
if (!brokerConfig.isEnableBuildConsumeQueueConcurrently()) {
if (!messageStoreConfig.isEnableBuildConsumeQueueConcurrently()) {
this.reputMessageService = new ReputMessageService();
} else {
this.reputMessageService = new ConcurrentReputMessageService();
@@ -689,7 +689,7 @@ public class DefaultMessageStore implements MessageStore {
this.recoverTopicQueueTable();
if (!brokerConfig.isEnableBuildConsumeQueueConcurrently()) {
if (!messageStoreConfig.isEnableBuildConsumeQueueConcurrently()) {
this.reputMessageService = new ReputMessageService();
} else {
this.reputMessageService = new ConcurrentReputMessageService();