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 bfce844a70ba70412793000e8aef228df571a54e Author: Claus Ibsen <[email protected]> AuthorDate: Mon May 18 16:49:55 2026 +0200 CAMEL-23544: propagate routeId to nested consumer in DefaultPlatformHttpConsumer Override setRouteId() to forward the routeId to the inner PlatformHttpConsumer so that exchanges created by platform-http routes carry the correct fromRouteId. This was already fixed in PR #23286 but was missing from this branch. Co-Authored-By: Claude Sonnet 4.6 <[email protected]> --- .../component/platform/http/DefaultPlatformHttpConsumer.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/DefaultPlatformHttpConsumer.java b/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/DefaultPlatformHttpConsumer.java index 6c2298561b8e..fd760be971bc 100644 --- a/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/DefaultPlatformHttpConsumer.java +++ b/components/camel-platform-http/src/main/java/org/apache/camel/component/platform/http/DefaultPlatformHttpConsumer.java @@ -22,6 +22,7 @@ import org.apache.camel.Processor; import org.apache.camel.Suspendable; import org.apache.camel.component.platform.http.spi.PlatformHttpConsumer; import org.apache.camel.component.platform.http.spi.PlatformHttpConsumerAware; +import org.apache.camel.spi.RouteIdAware; import org.apache.camel.support.DefaultConsumer; import org.apache.camel.support.service.ServiceHelper; @@ -68,6 +69,14 @@ public class DefaultPlatformHttpConsumer extends DefaultConsumer this.afterConfiguredListener = listener; } + @Override + public void setRouteId(String routeId) { + super.setRouteId(routeId); + if (platformHttpConsumer instanceof RouteIdAware ria) { + ria.setRouteId(routeId); + } + } + @Override protected void doInit() throws Exception { platformHttpConsumer = getEndpoint().createPlatformHttpConsumer(getProcessor());
