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
commit 3fd87499ec364633f4b856f3547e2e050dcc41f7
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Thu Aug 18 10:08:09 2022 +0200
CAMEL-18389: camel-jbang - camel ps til list running camel applications.
---
.../dsl/jbang/core/commands/CamelJBangMain.java | 1 +
.../camel/dsl/jbang/core/commands/ListProcess.java | 84 ++++++++++++++++++++++
2 files changed, 85 insertions(+)
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/CamelJBangMain.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/CamelJBangMain.java
index 05f370032d7..1f97191f857 100644
---
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/CamelJBangMain.java
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/CamelJBangMain.java
@@ -31,6 +31,7 @@ public class CamelJBangMain implements Callable<Integer> {
CamelJBangMain main = new CamelJBangMain();
commandLine = new CommandLine(main)
.addSubcommand("run", new CommandLine(new Run(main)))
+ .addSubcommand("ps", new CommandLine(new ListProcess(main)))
.addSubcommand("init", new CommandLine(new Init(main)))
.addSubcommand("bind", new CommandLine(new Bind(main)))
.addSubcommand("pipe", new CommandLine(new Pipe(main)))
diff --git
a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ListProcess.java
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ListProcess.java
new file mode 100644
index 00000000000..97aa43f0ae9
--- /dev/null
+++
b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/ListProcess.java
@@ -0,0 +1,84 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.dsl.jbang.core.commands;
+
+import org.apache.camel.util.ObjectHelper;
+import org.apache.camel.util.StringHelper;
+import org.apache.camel.util.TimeUtils;
+import picocli.CommandLine;
+import picocli.CommandLine.Command;
+
+@Command(name = "ps", description = "List running Camel applications")
+class ListProcess extends CamelCommand {
+
+ @CommandLine.Option(names = { "--sort" },
+ description = "Sort by pid, name or age", defaultValue = "pid")
+ private String sort;
+
+ public ListProcess(CamelJBangMain main) {
+ super(main);
+ }
+
+ @Override
+ public Integer call() throws Exception {
+ ProcessHandle.allProcesses()
+ .sorted((o1, o2) -> {
+ int answer = 0;
+ switch (sort) {
+ case "pid":
+ answer = Long.compare(o1.pid(), o2.pid());
+ break;
+ case "name":
+ answer =
extractName(o1).compareTo(extractName(o2));
+ break;
+ case "age":
+ // we want newest in top
+ answer = Long.compare(extractSince(o1),
extractSince(o2)) * -1;
+ break;
+ }
+ return answer;
+ })
+ .forEach(ph -> {
+ String name = extractName(ph);
+ if (ObjectHelper.isNotEmpty(name)) {
+ String ago = TimeUtils.printSince(extractSince(ph));
+ System.out.println(ph.pid() + " camel run " + name + " (age: "
+ ago + ")");
+ }
+ });
+ return 0;
+ }
+
+ private static String extractName(ProcessHandle ph) {
+ String cl = ph.info().commandLine().orElse("");
+ String name = StringHelper.after(cl, "main.CamelJBang run");
+ if (name != null) {
+ name = name.trim();
+ } else {
+ name = "";
+ }
+ return name;
+ }
+
+ private static long extractSince(ProcessHandle ph) {
+ long since = 0;
+ if (ph.info().startInstant().isPresent()) {
+ since = ph.info().startInstant().get().toEpochMilli();
+ }
+ return since;
+ }
+
+}
