[camel] branch main updated: enabling aws secret refresh should automatic trigger context reload enabled.

[davsclaus]

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

davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git


The following commit(s) were added to refs/heads/main by this push:
     new c6041169d4d enabling aws secret refresh should automatic trigger 
context reload enabled.
c6041169d4d is described below

commit c6041169d4dd0a5728e9af25f7a4ea6759a0c8d7
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Sep 8 12:43:18 2022 +0200

    enabling aws secret refresh should automatic trigger context reload enabled.
---
 .../src/main/java/org/apache/camel/main/BaseMainSupport.java   | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

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 94a24813cfe..b1451aca40f 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
@@ -48,11 +48,12 @@ import org.apache.camel.console.DevConsoleRegistry;
 import org.apache.camel.health.HealthCheck;
 import org.apache.camel.health.HealthCheckRegistry;
 import org.apache.camel.health.HealthCheckRepository;
-import org.apache.camel.impl.event.CamelContextRoutesStartedEvent;
+import org.apache.camel.impl.engine.DefaultContextReloadStrategy;
 import org.apache.camel.saga.CamelSagaService;
 import org.apache.camel.spi.AutowiredLifecycleStrategy;
 import org.apache.camel.spi.CamelBeanPostProcessor;
 import org.apache.camel.spi.CamelEvent;
+import org.apache.camel.spi.ContextReloadStrategy;
 import org.apache.camel.spi.DataFormat;
 import org.apache.camel.spi.Language;
 import org.apache.camel.spi.PackageScanClassResolver;
@@ -404,6 +405,11 @@ public abstract class BaseMainSupport extends BaseService {
                 if (LOG.isDebugEnabled()) {
                     LOG.debug("Scheduling: {} (period: {})", r, 
TimeUtils.printDuration(period, false));
                 }
+                if (camelContext.hasService(ContextReloadStrategy.class) == 
null) {
+                    // refresh is enabled then we need to automatically enable 
context-reload as well
+                    ContextReloadStrategy reloader = new 
DefaultContextReloadStrategy();
+                    camelContext.addService(reloader);
+                }
                 PeriodTaskScheduler scheduler = 
getCamelContext().adapt(ExtendedCamelContext.class).getPeriodTaskScheduler();
                 scheduler.schedulePeriodTask(r, period);
             }
@@ -672,7 +678,7 @@ public abstract class BaseMainSupport extends BaseService {
             camelContext.getManagementStrategy().addEventNotifier(new 
EventNotifierSupport() {
                 @Override
                 public boolean isEnabled(CamelEvent event) {
-                    return event instanceof CamelContextRoutesStartedEvent;
+                    return event instanceof 
CamelEvent.CamelContextRoutesStartedEvent;
                 }
 
                 @Override