refactor: remove static from executorService to support multi-broker in single process with brokercontainer (#9772)

RongtongJin · web-flow · commit 08b62b9d6759 · 2025-10-22T19:17:38.000+08:00
Change-Id: Ic1993e6f13a03c02af321cf94896ada58ec0f1b3
Co-developed-by: Cursor &lt;noreply@cursor.com&gt;
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
@@ -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() {
     }

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,7 @@ public abstract class AbstractTransactionalMessageCheckListener {`
`39`	`39`	`//queue nums of topic TRANS_CHECK_MAX_TIME_TOPIC`
`40`	`40`	`protected final static int TCMT_QUEUE_NUMS = 1;`
`41`	`41`
`42`		`- private static volatile ExecutorService executorService;`
	`42`	`+ private volatile ExecutorService executorService;`
`43`	`43`
`44`	`44`	`public AbstractTransactionalMessageCheckListener() {`
`45`	`45`	`}`