This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch ih in repository https://gitbox.apache.org/repos/asf/camel.git
commit 64a0db9f37a6eefd50c36f6ac445505fc72d10af Author: Claus Ibsen <[email protected]> AuthorDate: Thu Nov 20 13:06:38 2025 +0100 CAMEL-22693: Mark up EIP and endpoint headers that are of importance to make tooling, trouble shooting and development easier. --- .../debugger/DefaultBacklogTracerEventMessage.java | 2 +- .../core/commands/action/CamelHistoryAction.java | 27 ++++++++++++++++++++++ 2 files changed, 28 insertions(+), 1 deletion(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/DefaultBacklogTracerEventMessage.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/DefaultBacklogTracerEventMessage.java index 01caaeedb11d..6bdae766f16c 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/DefaultBacklogTracerEventMessage.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/DefaultBacklogTracerEventMessage.java @@ -522,7 +522,7 @@ public final class DefaultBacklogTracerEventMessage implements BacklogTracerEven jo.put("nodeShortName", toNodeShortName); } if (toNodeLabel != null) { - jo.put("nodeLabel", toNodeLabel); + jo.put("nodeLabel", Jsoner.escape(toNodeLabel)); } if (exchangeId != null) { jo.put("exchangeId", exchangeId); diff --git a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java index aabede65d651..1e42acc06176 100644 --- a/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java +++ b/dsl/camel-jbang/camel-jbang-core/src/main/java/org/apache/camel/dsl/jbang/core/commands/action/CamelHistoryAction.java @@ -22,6 +22,7 @@ import java.nio.file.Path; import java.util.ArrayList; import java.util.Arrays; import java.util.List; +import java.util.StringJoiner; import com.github.freva.asciitable.AsciiTable; import com.github.freva.asciitable.Column; @@ -157,6 +158,32 @@ public class CamelHistoryAction extends ActionWatchCommand { if (r.last) { return r.failed ? "failed" : "success"; } + return importantMessage(r); + } + + private static String importantMessage(Row r) { + StringJoiner sj = new StringJoiner(" "); + JsonArray arr = r.message.getCollection("exchangeProperties"); + if (arr != null) { + for (int i = 0; i < arr.size(); i++) { + JsonObject jo = (JsonObject) arr.get(i); + if (jo.getBooleanOrDefault("important", false)) { + sj.add(jo.getString("key") + "=" + jo.getString("value")); + } + } + } + arr = r.message.getCollection("headers"); + if (arr != null) { + for (int i = 0; i < arr.size(); i++) { + JsonObject jo = (JsonObject) arr.get(i); + if (jo.getBooleanOrDefault("important", false)) { + sj.add(jo.getString("key") + "=" + jo.getString("value")); + } + } + } + if (sj.length() > 0) { + return sj.toString(); + } return null; }
