This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch feat/camel-tui in repository https://gitbox.apache.org/repos/asf/camel.git
commit ddfb351a6ffa6a4aeaab5e23ea1aaf3b196ffcfd Author: Claus Ibsen <[email protected]> AuthorDate: Mon May 18 12:25:24 2026 +0200 Refactor BacklogTracer.traceBeforeNode/traceAfterNode into shared private helper Both methods had identical logic; extract into private traceNode() to eliminate duplication. Co-Authored-By: Claude Sonnet 4.6 <[email protected]> --- .../apache/camel/impl/debugger/BacklogTracer.java | 25 +++++----------------- 1 file changed, 5 insertions(+), 20 deletions(-) diff --git a/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/BacklogTracer.java b/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/BacklogTracer.java index 6b13e4f7b4f6..369ac6ddc218 100644 --- a/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/BacklogTracer.java +++ b/core/camel-base-engine/src/main/java/org/apache/camel/impl/debugger/BacklogTracer.java @@ -144,30 +144,15 @@ public class BacklogTracer extends ServiceSupport implements org.apache.camel.sp @Override public void traceBeforeNode(NamedNode node, Exchange exchange) { - if (!shouldTrace(node, exchange)) { - return; - } - long timestamp = System.currentTimeMillis(); - String toNode = node.getId(); - String toNodeParentId = node.getParentId(); - String toNodeShortName = node.getShortName(); - String toNodeLabel = StringHelper.limitLength(node.getLabel(), 50); - String exchangeId = exchange.getExchangeId(); - String correlationExchangeId = exchange.getProperty(ExchangePropertyKey.CORRELATION_ID, String.class); - int level = node.getLevel(); - String fromRouteId = exchange.getFromRouteId(); - String source = LoggerHelper.getLineNumberLoggerName(node); - JsonObject data = MessageHelper.dumpAsJSonObject(exchange.getIn(), isIncludeExchangeProperties(), - isIncludeExchangeVariables(), true, true, isBodyIncludeStreams(), isBodyIncludeFiles(), getBodyMaxChars()); - DefaultBacklogTracerEventMessage event = new DefaultBacklogTracerEventMessage( - camelContext, false, false, incrementTraceCounter(), timestamp, source, fromRouteId, fromRouteId, toNode, - toNodeParentId, null, null, toNodeShortName, toNodeLabel, level, - exchangeId, correlationExchangeId, false, false, data); - traceEvent(event); + traceNode(node, exchange); } @Override public void traceAfterNode(NamedNode node, Exchange exchange) { + traceNode(node, exchange); + } + + private void traceNode(NamedNode node, Exchange exchange) { if (!shouldTrace(node, exchange)) { return; }
