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

ltamber 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 08b62b9d67 refactor: remove static from executorService to support 
multi-broker in single process with brokercontainer (#9772)
08b62b9d67 is described below

commit 08b62b9d675912d24d7f548b071ec06099154c75
Author: rongtong <[email protected]>
AuthorDate: Wed Oct 22 19:17:38 2025 +0800

    refactor: remove static from executorService to support multi-broker in 
single process with brokercontainer (#9772)
    
    Change-Id: Ic1993e6f13a03c02af321cf94896ada58ec0f1b3
    Co-developed-by: Cursor <[email protected]>
---
 .../broker/transaction/AbstractTransactionalMessageCheckListener.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
 
b/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
index c6713f0496..d1b77355b0 100644
--- 
a/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
+++ 
b/broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
@@ -39,7 +39,7 @@ public abstract class 
AbstractTransactionalMessageCheckListener {
     //queue nums of topic TRANS_CHECK_MAX_TIME_TOPIC
     protected final static int TCMT_QUEUE_NUMS = 1;
 
-    private static volatile ExecutorService executorService;
+    private volatile ExecutorService executorService;
 
     public AbstractTransactionalMessageCheckListener() {
     }

Reply via email to