(camel) branch main updated: CAMEL-23851: camel-debug - Fix breakpoint on first EIP incorrectly stopping at route input (#24314)

[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 9ad7551148f5 CAMEL-23851: camel-debug - Fix breakpoint on first EIP 
incorrectly stopping at route input (#24314)
9ad7551148f5 is described below

commit 9ad7551148f5ddc4b6cd63549ca6858332609c9c
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Mon Jun 29 10:54:10 2026 +0200

    CAMEL-23851: camel-debug - Fix breakpoint on first EIP incorrectly stopping 
at route input (#24314)
    
    Signed-off-by: Claus Ibsen <claus.ib...@gmail.com>
    Co-authored-by: Claude Opus 4.6 <nore...@anthropic.com>
---
 .../java/org/apache/camel/impl/engine/DefaultChannel.java     | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java
 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java
index 34c4acb82499..432612f68c93 100644
--- 
a/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java
+++ 
b/core/camel-base-engine/src/main/java/org/apache/camel/impl/engine/DefaultChannel.java
@@ -347,10 +347,14 @@ public class DefaultChannel extends 
CamelInternalProcessor implements Channel {
         // setup initial breakpoints
         if (debugger.getInitialBreakpoints() != null) {
             boolean match = false;
+            boolean allRoutes = false;
             String id = definition.getId();
             for (String pattern : debugger.getInitialBreakpoints().split(",")) 
{
                 pattern = pattern.trim();
-                match |= BacklogDebugger.BREAKPOINT_ALL_ROUTES.equals(pattern) 
&& first;
+                if (BacklogDebugger.BREAKPOINT_ALL_ROUTES.equals(pattern) && 
first) {
+                    match = true;
+                    allRoutes = true;
+                }
                 if (!match) {
                     match = PatternHelper.matchPattern(id, pattern);
                 }
@@ -387,13 +391,12 @@ public class DefaultChannel extends 
CamelInternalProcessor implements Channel {
                 }
             }
             if (match) {
-                if (first && debugger.isSingleStepIncludeStartEnd()) {
-                    // we want route to be breakpoint (use input)
+                if (allRoutes && first && 
debugger.isSingleStepIncludeStartEnd()) {
+                    // all routes breakpoint: we want route to be breakpoint 
(use input)
                     id = routeDefinition.getInput().getId();
                     debugger.addBreakpoint(id);
                     LOG.debug("BacklogDebugger added breakpoint: {}", id);
                 } else {
-                    // first output should also be breakpoint
                     id = targetOutputDef.getId();
                     debugger.addBreakpoint(id);
                     LOG.debug("BacklogDebugger added breakpoint: {}", id);