This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel.git
commit b3da2f2425b36b79eb753dcacf3b3e89a8703a9e Author: Claus Ibsen <[email protected]> AuthorDate: Wed Feb 2 18:57:18 2022 +0100 CAMEL-17588: Reactive executor should clean thread local on shutdown. --- .../java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java index 6ac6e2f..b9ef7e3 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultReactiveExecutor.java @@ -122,6 +122,12 @@ public class DefaultReactiveExecutor extends ServiceSupport implements ReactiveE } } + @Override + protected void doShutdown() throws Exception { + // cleanup workers + workers.remove(); + } + private static class Worker { private final int number;
