[camel] 02/02: camel-core - Fix backlog tracer captuing source location for route input

[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

commit de990047ecefeed3ad6a7e613a9b48613295cd1a
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Fri Feb 17 19:08:00 2023 +0100

    camel-core - Fix backlog tracer captuing source location for route input
---
 .../java/org/apache/camel/impl/engine/CamelInternalProcessor.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
index 6fc1722509d..b2e43365735 100644
--- 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
+++ 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/CamelInternalProcessor.java
@@ -594,8 +594,9 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor implements In
 
                 // if first we should add a pseudo trace message as well, so 
we have a starting message (eg from the route)
                 String routeId = routeDefinition != null ? 
routeDefinition.getRouteId() : null;
-                String source = 
LoggerHelper.getLineNumberLoggerName(processorDefinition);
                 if (first) {
+                    // use route as pseudo source when first
+                    String source = 
LoggerHelper.getLineNumberLoggerName(routeDefinition);
                     long created = exchange.getCreated();
                     DefaultBacklogTracerEventMessage pseudoFirst = new 
DefaultBacklogTracerEventMessage(
                             true, false, 
backlogTracer.incrementTraceCounter(), created, source, routeId, null, 
exchangeId,
@@ -631,6 +632,7 @@ public class CamelInternalProcessor extends 
DelegateAsyncProcessor implements In
                         }
                     });
                 }
+                String source = 
LoggerHelper.getLineNumberLoggerName(processorDefinition);
                 DefaultBacklogTracerEventMessage event = new 
DefaultBacklogTracerEventMessage(
                         false, false, backlogTracer.incrementTraceCounter(), 
timestamp, source, routeId, toNode, exchangeId,
                         messageAsXml,