This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/master by this push:
new 8f60417 Cleanup TimeOutChecker threads
8f60417 is described below
commit 8f60417d647e4a17a6f57b64e498bb3b6d049608
Author: Sudharsan Govindarajan <[email protected]>
AuthorDate: Tue Jun 19 13:37:52 2018 +0200
Cleanup TimeOutChecker threads
When a Aggregator route is stopped, only the AggregateRecoveryChecker
threads are stopped and not the AggregateTimeoutChecker threads. They keep
lingering around .
---
.../org/apache/camel/processor/aggregate/AggregateProcessor.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git
a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
index 18fc42c..81417cd 100644
---
a/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
+++
b/camel-core/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java
@@ -1448,6 +1448,11 @@ public class AggregateProcessor extends ServiceSupport
implements AsyncProcessor
if (recoverService != null) {
camelContext.getExecutorServiceManager().shutdown(recoverService);
}
+
+ if (timeoutCheckerExecutorService != null) {
+
camelContext.getExecutorServiceManager().shutdownNow(timeoutCheckerExecutorService);
+ }
+
ServiceHelper.stopServices(timeoutMap, processor,
deadLetterProducerTemplate);
if (closedCorrelationKeys != null) {
