[camel-k-runtime] branch main updated: fix(cron): gracefully stop when all exchanges are processed

[pcongiusti]

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

pcongiusti pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-k-runtime.git


The following commit(s) were added to refs/heads/main by this push:
     new 1a5e48ff fix(cron): gracefully stop when all exchanges are processed
1a5e48ff is described below

commit 1a5e48ff3a7ae551b53af0df53ffc8654109e2a9
Author: Pasquale Congiusti <pasquale.congiu...@gmail.com>
AuthorDate: Fri May 19 12:39:32 2023 +0200

    fix(cron): gracefully stop when all exchanges are processed
    
    Closes https://github.com/apache/camel-k/issues/4343
---
 .../main/java/org/apache/camel/k/cron/CronSourceLoaderInterceptor.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/camel-k-cron/impl/src/main/java/org/apache/camel/k/cron/CronSourceLoaderInterceptor.java
 
b/camel-k-cron/impl/src/main/java/org/apache/camel/k/cron/CronSourceLoaderInterceptor.java
index 8616249b..dd36f0e0 100644
--- 
a/camel-k-cron/impl/src/main/java/org/apache/camel/k/cron/CronSourceLoaderInterceptor.java
+++ 
b/camel-k-cron/impl/src/main/java/org/apache/camel/k/cron/CronSourceLoaderInterceptor.java
@@ -131,7 +131,8 @@ public class CronSourceLoaderInterceptor implements 
RouteBuilderLifecycleStrateg
 
         @Override
         public boolean isEnabled(CamelEvent event) {
-            return event instanceof CamelEvent.ExchangeCompletedEvent || event 
instanceof CamelEvent.ExchangeFailedEvent;
+            return (event instanceof CamelEvent.ExchangeCompletedEvent || 
event instanceof CamelEvent.ExchangeFailedEvent)
+                && 
this.runtime.getCamelContext().getInflightRepository().size() == 0;
         }
     }
 }