[rocketmq] branch develop updated: [ISSUE #7271] Optimize the configuration for setting the quantity of TimerDequeuePutMessageService (#7272)

[jinrongtong]

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

jinrongtong 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 b4f73e2aab [ISSUE #7271] Optimize the configuration for setting the 
quantity of TimerDequeuePutMessageService (#7272)
b4f73e2aab is described below

commit b4f73e2aabc1b141cec98431899e4090340adf0f
Author: mxsm <ljbm...@gmail.com>
AuthorDate: Sun Aug 27 20:58:58 2023 +0800

    [ISSUE #7271] Optimize the configuration for setting the quantity of 
TimerDequeuePutMessageService (#7272)
---
 .../main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java 
b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
index 690f4863e6..181f7087ae 100644
--- a/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
+++ b/store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
@@ -222,7 +222,7 @@ public class TimerMessageStore {
             dequeueGetMessageServices[i] = new TimerDequeueGetMessageService();
         }
 
-        int putThreadNum = Math.max(storeConfig.getTimerGetMessageThreadNum(), 
1);
+        int putThreadNum = Math.max(storeConfig.getTimerPutMessageThreadNum(), 
1);
         dequeuePutMessageServices = new 
TimerDequeuePutMessageService[putThreadNum];
         for (int i = 0; i < dequeuePutMessageServices.length; i++) {
             dequeuePutMessageServices[i] = new TimerDequeuePutMessageService();