From ecdbd05f7f298a410b5abe5d4d54ef8cee771ef4 Mon Sep 17 00:00:00 2001 From: jinhaiyang Date: Fri, 23 Aug 2024 10:37:42 +0800 Subject: [PATCH] ThreadLocal remove --- .../java/cn/axzo/framework/rocketmq/AfterCommitExecutorImpl.java | 1 + 1 file changed, 1 insertion(+) diff --git a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AfterCommitExecutorImpl.java b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AfterCommitExecutorImpl.java index 5817136..cf16b15 100644 --- a/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AfterCommitExecutorImpl.java +++ b/axzo-common-rocketmq/src/main/java/cn/axzo/framework/rocketmq/AfterCommitExecutorImpl.java @@ -82,6 +82,7 @@ public class AfterCommitExecutorImpl extends TransactionSynchronizationAdapter { } } RUNNABLES.remove(); + ROLLBACK_RUNNABLES.remove(); } public List getRunnables() {