(camel) branch main updated: CAMEL-20528: camel-console - Make it possible to easily start and stop routes via dev console

[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 ae17a91c89a CAMEL-20528: camel-console - Make it possible to easily 
start and stop routes via dev console
ae17a91c89a is described below

commit ae17a91c89a02e51f1358717708a441917a5d4fc
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Mar 7 07:20:07 2024 +0100

    CAMEL-20528: camel-console - Make it possible to easily start and stop 
routes via dev console
---
 .../apache/camel/impl/console/RouteDevConsole.java | 70 ++++++++++++++++++++++
 1 file changed, 70 insertions(+)

diff --git 
a/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
 
b/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
index 1e6ee27a284..a289c96982e 100644
--- 
a/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
+++ 
b/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteDevConsole.java
@@ -25,6 +25,7 @@ import java.util.Map;
 import java.util.Objects;
 import java.util.function.Function;
 
+import org.apache.camel.CamelContext;
 import org.apache.camel.Exchange;
 import org.apache.camel.Route;
 import org.apache.camel.api.management.ManagedCamelContext;
@@ -57,12 +58,24 @@ public class RouteDevConsole extends AbstractDevConsole {
      */
     public static final String PROCESSORS = "processors";
 
+    /**
+     * Action to perform such as start,stop,suspend,resume on one or more 
routes
+     */
+    public static final String ACTION = "action";
+
     public RouteDevConsole() {
         super("camel", "route", "Route", "Route information");
     }
 
     @Override
     protected String doCallText(Map<String, Object> options) {
+        String action = (String) options.get(ACTION);
+        String filter = (String) options.get(FILTER);
+        if (action != null) {
+            doAction(getCamelContext(), action, filter);
+            return "";
+        }
+
         final boolean processors = 
"true".equals(options.getOrDefault(PROCESSORS, "false"));
         final StringBuilder sb = new StringBuilder();
         Function<ManagedRouteMBean, Object> task = mrb -> {
@@ -202,6 +215,13 @@ public class RouteDevConsole extends AbstractDevConsole {
 
     @Override
     protected JsonObject doCallJson(Map<String, Object> options) {
+        String action = (String) options.get(ACTION);
+        String filter = (String) options.get(FILTER);
+        if (action != null) {
+            doAction(getCamelContext(), action, filter);
+            return new JsonObject();
+        }
+
         final boolean processors = 
"true".equals(options.getOrDefault(PROCESSORS, "false"));
         final JsonObject root = new JsonObject();
         final List<JsonObject> list = new ArrayList<>();
@@ -447,4 +467,54 @@ public class RouteDevConsole extends AbstractDevConsole {
         }
     }
 
+    protected void doAction(CamelContext camelContext, String command, String 
filter) {
+        if (filter == null) {
+            filter = "*";
+        }
+        String[] patterns = filter.split(",");
+        // find matching IDs
+        List<String> ids = camelContext.getRoutes()
+                .stream().map(Route::getRouteId)
+                .filter(routeId -> {
+                    for (String p : patterns) {
+                        if (PatternHelper.matchPattern(routeId, p)) {
+                            return true;
+                        }
+                    }
+                    return false;
+                })
+                .toList();
+        for (String id : ids) {
+            try {
+                if ("start".equals(command)) {
+                    if ("*".equals(id)) {
+                        camelContext.getRouteController().startAllRoutes();
+                    } else {
+                        camelContext.getRouteController().startRoute(id);
+                    }
+                } else if ("stop".equals(command)) {
+                    if ("*".equals(id)) {
+                        camelContext.getRouteController().stopAllRoutes();
+                    } else {
+                        camelContext.getRouteController().stopRoute(id);
+                    }
+                } else if ("suspend".equals(command)) {
+                    if ("*".equals(id)) {
+                        camelContext.suspend();
+                    } else {
+                        camelContext.getRouteController().suspendRoute(id);
+                    }
+                } else if ("resume".equals(command)) {
+                    if ("*".equals(id)) {
+                        camelContext.resume();
+                    } else {
+                        camelContext.getRouteController().resumeRoute(id);
+                    }
+                }
+            } catch (Exception e) {
+                // ignore
+            }
+        }
+    }
+
 }