camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acosent...@apache.org
Subject [camel] branch master updated: Cleanup TimeOutChecker threads
Date Tue, 19 Jun 2018 12:15:46 GMT
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 <gsudharsan@users.noreply.github.com>
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) {


Mime
View raw message