[rocketmq] branch 5.0.0-alpha updated: [ISSUE #3436] Make configuration for pop be configurable (#3437)

[du...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a commit to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/5.0.0-alpha by this push:
     new 0f5a0a1  [ISSUE #3436] Make configuration for pop be configurable (#3437)
0f5a0a1 is described below

commit 0f5a0a1e64234e1fbd6c50277ef31831d9003767
Author: cserwen <cs...@163.com>
AuthorDate: Fri Oct 29 17:38:13 2021 +0800

    [ISSUE #3436] Make configuration for pop be configurable (#3437)
    
    * bugfix: configuration enablePopBufferMerge not work
    
    * make configration for pop be configurable
    
    Co-authored-by: dengzhiwen1 <de...@xiaomi.com>
---
 .../org/apache/rocketmq/common/BrokerConfig.java   | 54 +++++++++++++++++++++-
 1 file changed, 52 insertions(+), 2 deletions(-)

diff --git a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
index bf2355c..1b74eaa 100644
--- a/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
+++ b/common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
@@ -238,54 +238,106 @@ public class BrokerConfig {
         return maxPopPollingSize;
     }
 
+    public void setMaxPopPollingSize(long maxPopPollingSize) {
+        this.maxPopPollingSize = maxPopPollingSize;
+    }
+
     public int getReviveQueueNum() {
         return reviveQueueNum;
     }
 
+    public void setReviveQueueNum(int reviveQueueNum) {
+        this.reviveQueueNum = reviveQueueNum;
+    }
+
     public long getReviveInterval() {
         return reviveInterval;
     }
 
+    public void setReviveInterval(long reviveInterval) {
+        this.reviveInterval = reviveInterval;
+    }
+
     public int getPopCkStayBufferTime() {
         return popCkStayBufferTime;
     }
 
+    public void setPopCkStayBufferTime(int popCkStayBufferTime) {
+        this.popCkStayBufferTime = popCkStayBufferTime;
+    }
+
     public int getPopCkStayBufferTimeOut() {
         return popCkStayBufferTimeOut;
     }
 
+    public void setPopCkStayBufferTimeOut(int popCkStayBufferTimeOut) {
+        this.popCkStayBufferTimeOut = popCkStayBufferTimeOut;
+    }
+
     public int getPopPollingMapSize() {
         return popPollingMapSize;
     }
 
+    public void setPopPollingMapSize(int popPollingMapSize) {
+        this.popPollingMapSize = popPollingMapSize;
+    }
+
     public long getReviveScanTime() {
         return reviveScanTime;
     }
 
+    public void setReviveScanTime(long reviveScanTime) {
+        this.reviveScanTime = reviveScanTime;
+    }
+
     public long getReviveMaxSlow() {
         return reviveMaxSlow;
     }
 
+    public void setReviveMaxSlow(long reviveMaxSlow) {
+        this.reviveMaxSlow = reviveMaxSlow;
+    }
+
     public int getPopPollingSize() {
         return popPollingSize;
     }
 
+    public void setPopPollingSize(int popPollingSize) {
+        this.popPollingSize = popPollingSize;
+    }
+
     public boolean isEnablePopBufferMerge() {
         return enablePopBufferMerge;
     }
 
+    public void setEnablePopBufferMerge(boolean enablePopBufferMerge) {
+        this.enablePopBufferMerge = enablePopBufferMerge;
+    }
+
     public int getPopCkMaxBufferSize() {
         return popCkMaxBufferSize;
     }
 
+    public void setPopCkMaxBufferSize(int popCkMaxBufferSize) {
+        this.popCkMaxBufferSize = popCkMaxBufferSize;
+    }
+
     public int getPopCkOffsetMaxQueueSize() {
         return popCkOffsetMaxQueueSize;
     }
 
+    public void setPopCkOffsetMaxQueueSize(int popCkOffsetMaxQueueSize) {
+        this.popCkOffsetMaxQueueSize = popCkOffsetMaxQueueSize;
+    }
+
     public boolean isEnablePopLog() {
         return enablePopLog;
     }
 
+    public void setEnablePopLog(boolean enablePopLog) {
+        this.enablePopLog = enablePopLog;
+    }
+
     public boolean isTraceOn() {
         return traceOn;
     }
@@ -950,12 +1002,10 @@ public class BrokerConfig {
         this.defaultMessageRequestMode = MessageRequestMode.valueOf(defaultMessageRequestMode);
     }
 
-
     public int getDefaultPopShareQueueNum() {
         return defaultPopShareQueueNum;
     }
 
-
     public void setDefaultPopShareQueueNum(int defaultPopShareQueueNum) {
         this.defaultPopShareQueueNum = defaultPopShareQueueNum;
     }