You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2018/06/20 12:45:43 UTC
[camel] 02/02: Revert "Cleanup TimeOutChecker threads"
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
commit 2ad153385592980e4381c18534829d0fe7c2bc59
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Jun 20 14:44:57 2018 +0200
Revert "Cleanup TimeOutChecker threads"
This reverts commit 8f60417d647e4a17a6f57b64e498bb3b6d049608.
---
.../org/apache/camel/processor/aggregate/AggregateProcessor.java | 5 -----
1 file changed, 5 deletions(-)
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 81417cd..18fc42c 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,11 +1448,6 @@ 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) {