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() {
}