[camel] branch main updated: CAMEL-18533: camel-netty - TimeoutCorrelationManagerSupport should stop created thread-pools

[davsclaus]

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


The following commit(s) were added to refs/heads/main by this push:
     new 5224a31e7df CAMEL-18533: camel-netty - 
TimeoutCorrelationManagerSupport should stop created thread-pools
5224a31e7df is described below

commit 5224a31e7dfd858a9eea2b4926d61c60260cb5e1
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Wed Sep 21 12:16:52 2022 +0200

    CAMEL-18533: camel-netty - TimeoutCorrelationManagerSupport should stop 
created thread-pools
---
 .../apache/camel/component/netty/TimeoutCorrelationManagerSupport.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/components/camel-netty/src/main/java/org/apache/camel/component/netty/TimeoutCorrelationManagerSupport.java
 
b/components/camel-netty/src/main/java/org/apache/camel/component/netty/TimeoutCorrelationManagerSupport.java
index bbeeeb0d850..e33e47e1b9d 100644
--- 
a/components/camel-netty/src/main/java/org/apache/camel/component/netty/TimeoutCorrelationManagerSupport.java
+++ 
b/components/camel-netty/src/main/java/org/apache/camel/component/netty/TimeoutCorrelationManagerSupport.java
@@ -179,9 +179,11 @@ public abstract class TimeoutCorrelationManagerSupport 
extends ServiceSupport
         if (scheduledExecutorService == null) {
             scheduledExecutorService = 
camelContext.getExecutorServiceManager().newSingleThreadScheduledExecutor(this,
                     "NettyTimeoutCorrelationManager");
+            stopScheduledExecutorService = true;
         }
         if (workerPool == null) {
             workerPool = 
camelContext.getExecutorServiceManager().newDefaultThreadPool(this, 
"NettyTimeoutWorkerPool");
+            stopWorkerPool = true;
         }
 
         map = new DefaultTimeoutMap<>(scheduledExecutorService, 
timeoutChecker);