Fix apache#222: shutting down the runtime instead of the Camel context

camel-k-runtime-core/src/main/java/org/apache/camel/k/Runtime.java

@@ -57,6 +57,14 @@ default void addConfiguration(Object configuration) {
         throw new UnsupportedOperationException();
     }
 
+    /**
+     * Lifecycle method used to stops the entire integration.
+     */
+    default void stop() throws Exception {
+        // Stopping the Camel context in default config is enough to tear down the integration
+        getCamelContext().stop();
+    }
+
     enum Phase {
         Starting,
         ConfigureContext,

camel-k-runtime-cron/src/main/java/org/apache/camel/k/cron/CronRoutePolicyFactory.java

@@ -20,6 +20,8 @@
 import org.apache.camel.Exchange;
 import org.apache.camel.NamedNode;
 import org.apache.camel.Route;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.k.Runtime;
 import org.apache.camel.spi.RoutePolicy;
 import org.apache.camel.spi.RoutePolicyFactory;
 import org.apache.camel.support.RoutePolicySupport;
@@ -31,17 +33,20 @@
  */
 public class CronRoutePolicyFactory implements RoutePolicyFactory {
 
-    public CronRoutePolicyFactory() {
+    private Runtime runtime;
+
+    public CronRoutePolicyFactory(Runtime runtime) {
+        this.runtime = runtime;
     }
 
     @Override
     public RoutePolicy createRoutePolicy(CamelContext camelContext, String routeId, NamedNode route) {
         return new CronRoutePolicy(camelContext);
     }
 
-    private static class CronRoutePolicy extends RoutePolicySupport {
+    private class CronRoutePolicy extends RoutePolicySupport {
 
-        private static final Logger LOG = LoggerFactory.getLogger(CronRoutePolicy.class);
+        private final Logger logger = LoggerFactory.getLogger(CronRoutePolicy.class);
 
         private final CamelContext context;
 
@@ -51,8 +56,16 @@ public CronRoutePolicy(CamelContext context) {
 
         @Override
         public void onExchangeDone(Route route, Exchange exchange) {
-            LOG.info("Context shutdown started by cron policy");
-            context.getExecutorServiceManager().newThread("terminator", context::stop).start();
+            logger.info("Context shutdown started by cron policy");
+            context.getExecutorServiceManager().newThread("terminator", this::stopRuntime).start();
+        }
+
+        private void stopRuntime() {
+            try {
+                runtime.stop();
+            } catch (Exception e) {
+                throw new RuntimeCamelException(e);
+            }
         }
 
     }

camel-k-runtime-cron/src/main/java/org/apache/camel/k/cron/CronRuntimeListener.java

@@ -51,7 +51,7 @@ protected void accept(Runtime runtime) {
         }
 
         // Add the cron route policy if there's at least one component to override
-        runtime.getCamelContext().addRoutePolicyFactory(new CronRoutePolicyFactory());
+        runtime.getCamelContext().addRoutePolicyFactory(new CronRoutePolicyFactory(runtime));
 
         // Override components
         overrideCron(runtime, components.split(",", -1));

camel-k-runtime-main/src/main/java/org/apache/camel/k/main/ApplicationRuntime.java

@@ -76,7 +76,8 @@ public void run() throws Exception {
         this.main.run();
     }
 
-    public void stop()throws Exception {
+    @Override
+    public void stop() throws Exception {
         this.main.stop();
     }