This is an automated email from the ASF dual-hosted git repository. davsclaus pushed a commit to branch topology-external-endpoints in repository https://gitbox.apache.org/repos/asf/camel.git
commit 7adf4a65a030fc772e771ea3be5d480c3c382c6b Author: Claus Ibsen <[email protected]> AuthorDate: Tue Jun 2 11:44:06 2026 +0200 Use URISupport.normalizeUri for endpoint metric matching Replace custom normalizeScheme helper with the standard URISupport.normalizeUri for consistent URI comparison. Co-Authored-By: Claude Opus 4.6 <[email protected]> --- .../apache/camel/impl/console/RouteTopologyDevConsole.java | 14 +++----------- 1 file changed, 3 insertions(+), 11 deletions(-) diff --git a/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteTopologyDevConsole.java b/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteTopologyDevConsole.java index 7c93adeca6fa..38b6e36a74b4 100644 --- a/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteTopologyDevConsole.java +++ b/core/camel-console/src/main/java/org/apache/camel/impl/console/RouteTopologyDevConsole.java @@ -169,15 +169,6 @@ public class RouteTopologyDevConsole extends AbstractDevConsole { return root; } - private static String normalizeScheme(String uri) { - // Normalize "scheme://path" to "scheme:path" for consistent matching - int idx = uri.indexOf("://"); - if (idx > 0) { - return uri.substring(0, idx) + ":" + uri.substring(idx + 3); - } - return uri; - } - /** * Collects per-endpoint metrics for producer endpoints by iterating managed send processors. Returns a map keyed by * "routeId|normalizedUri" with value [exchangesTotal, exchangesFailed]. @@ -192,6 +183,7 @@ public class RouteTopologyDevConsole extends AbstractDevConsole { continue; } try { + String epUri = URISupport.normalizeUri(ep.uri()); ManagedRouteMBean mrb = mcc.getManagedRoute(ep.routeId()); if (mrb == null) { continue; @@ -202,8 +194,8 @@ public class RouteTopologyDevConsole extends AbstractDevConsole { if (sp == null) { continue; } - String dest = normalizeScheme(URISupport.stripQuery(sp.getDestination())); - if (normalizeScheme(ep.uri()).equals(dest)) { + String dest = URISupport.normalizeUri(URISupport.stripQuery(sp.getDestination())); + if (epUri.equals(dest)) { String key = ep.routeId() + "|" + ep.uri(); long[] existing = metrics.get(key); if (existing != null) {
