This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/camel.git
commit bc2c52b9f112fe47fa59718ff6f704387d2c4f1d Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu May 28 09:54:22 2020 +0200 CAMEL-15126: camel-health - polished and fix TODO with route controller not an extension --- .../java/org/apache/camel/impl/engine/AbstractCamelContext.java | 8 ++++++-- .../src/main/java/org/apache/camel/impl/DefaultCamelContext.java | 6 ------ .../src/main/java/org/apache/camel/main/BaseMainSupport.java | 2 +- 3 files changed, 7 insertions(+), 9 deletions(-) diff --git a/core/camel-base/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java b/core/camel-base/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java index 4e3a469..a772ac7 100644 --- a/core/camel-base/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java +++ b/core/camel-base/src/main/java/org/apache/camel/impl/engine/AbstractCamelContext.java @@ -376,9 +376,8 @@ public abstract class AbstractCamelContext extends BaseService } }); + // TODO: setDefaultExtension(HealthCheckRegistry.class, this::createHealthCheckRegistry); - // TODO: is route controller needed as extension? - setDefaultExtension(RouteController.class, this::createRouteController); if (build) { try { @@ -3232,6 +3231,11 @@ public abstract class AbstractCamelContext extends BaseService } protected void doStartEagerServices() { + // initialize health-check registry + HealthCheckRegistry hcr = getExtension(HealthCheckRegistry.class); + if (hcr == null) { + setExtension(HealthCheckRegistry.class, createHealthCheckRegistry()); + } getFactoryFinderResolver(); getDefaultFactoryFinder(); getComponentResolver(); diff --git a/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultCamelContext.java b/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultCamelContext.java index a53f472..67e34f7 100644 --- a/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultCamelContext.java +++ b/core/camel-core-engine/src/main/java/org/apache/camel/impl/DefaultCamelContext.java @@ -298,12 +298,6 @@ public class DefaultCamelContext extends SimpleCamelContext implements ModelCame } @Override - protected void doStartEagerServices() { - getExtension(HealthCheckRegistry.class); - super.doStartEagerServices(); - } - - @Override protected void bindDataFormats() throws Exception { // eager lookup data formats and bind to registry so the dataformats can // be looked up and used diff --git a/core/camel-main/src/main/java/org/apache/camel/main/BaseMainSupport.java b/core/camel-main/src/main/java/org/apache/camel/main/BaseMainSupport.java index ef615c3..5bde1e9 100644 --- a/core/camel-main/src/main/java/org/apache/camel/main/BaseMainSupport.java +++ b/core/camel-main/src/main/java/org/apache/camel/main/BaseMainSupport.java @@ -403,7 +403,7 @@ public abstract class BaseMainSupport extends BaseService { if (mainConfigurationProperties.getPackageScanRouteBuilders() != null) { String[] pkgs = mainConfigurationProperties.getPackageScanRouteBuilders().split(","); - Set<Class<?>> set = camelContext.getExtension(ExtendedCamelContext.class).getPackageScanClassResolver().findImplementations(RoutesBuilder.class, pkgs); + Set<Class<?>> set = camelContext.adapt(ExtendedCamelContext.class).getPackageScanClassResolver().findImplementations(RoutesBuilder.class, pkgs); for (Class<?> routeClazz : set) { Object builder = camelContext.getInjector().newInstance(routeClazz); if (builder instanceof RoutesBuilder) {