[camel] branch master updated: CAMEL-12482: add support for custom ExecutorSer...

[zregvart]

This is an automated email from the ASF dual-hosted git repository.

zregvart 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 b22c3fe  CAMEL-12482: add support for custom ExecutorSer...
b22c3fe is described below

commit b22c3fe4be4262742c48bb89022466d68a71d042
Author: Zoran Regvart <zregv...@apache.org>
AuthorDate: Fri May 4 10:44:40 2018 +0200

    CAMEL-12482: add support for custom ExecutorSer...
    
    ...viceManager in CamelAutoConfiguration
    
    This adds a lookup of `ExecutorServiceManager` implementing bean when
    auto-configuring CamelContext in Spring Boot auto-configuration.
---
 .../java/org/apache/camel/spring/boot/CamelAutoConfiguration.java | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git 
a/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelAutoConfiguration.java
 
b/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelAutoConfiguration.java
index 4d1c95d..78a8dbb 100644
--- 
a/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelAutoConfiguration.java
+++ 
b/components/camel-spring-boot/src/main/java/org/apache/camel/spring/boot/CamelAutoConfiguration.java
@@ -44,6 +44,7 @@ import org.apache.camel.spi.AsyncProcessorAwaitManager;
 import org.apache.camel.spi.EndpointStrategy;
 import org.apache.camel.spi.EventFactory;
 import org.apache.camel.spi.EventNotifier;
+import org.apache.camel.spi.ExecutorServiceManager;
 import org.apache.camel.spi.InflightRepository;
 import org.apache.camel.spi.InterceptStrategy;
 import org.apache.camel.spi.LifecycleStrategy;
@@ -534,6 +535,13 @@ public class CamelAutoConfiguration {
             }
         }
 
+        // ExecutorServiceManager
+        final ExecutorServiceManager executorServiceManager = 
getSingleBeanOfType(applicationContext, ExecutorServiceManager.class);
+        if (executorServiceManager != null) {
+            LOG.info("Using custom ExecutorServiceManager: {}", 
executorServiceManager);
+            camelContext.setExecutorServiceManager(executorServiceManager);
+        }
+
         // set the default thread pool profile if defined
         initThreadPoolProfiles(applicationContext, camelContext);
     }

-- 
To stop receiving notification emails like this one, please contact
zregv...@apache.org.