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-spring-boot.git
The following commit(s) were added to refs/heads/main by this push: new 7b7899114b3 CAMEL-20650: camel-spring-boot - Platform http should report server port 7b7899114b3 is described below commit 7b7899114b3c2d42767fabc09e621dd1769bcf73 Author: Claus Ibsen <claus.ib...@gmail.com> AuthorDate: Thu Apr 4 16:03:38 2024 +0200 CAMEL-20650: camel-spring-boot - Platform http should report server port --- .../springboot/SpringBootPlatformHttpAutoConfiguration.java | 6 ++++-- .../platform/http/springboot/SpringBootPlatformHttpEngine.java | 10 ++++++++++ 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpAutoConfiguration.java b/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpAutoConfiguration.java index 49dc21d1282..e604dff895e 100644 --- a/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpAutoConfiguration.java +++ b/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpAutoConfiguration.java @@ -25,6 +25,7 @@ import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.DependsOn; +import org.springframework.core.env.Environment; @Configuration(proxyBeanMethods = false) @AutoConfigureAfter(name = { "org.apache.camel.component.servlet.springboot.PlatformHttpComponentAutoConfiguration", @@ -36,8 +37,9 @@ public class SpringBootPlatformHttpAutoConfiguration { @Bean(name = "platform-http-engine") @ConditionalOnMissingBean(PlatformHttpEngine.class) - public PlatformHttpEngine springBootPlatformHttpEngine() { - return new SpringBootPlatformHttpEngine(); + public PlatformHttpEngine springBootPlatformHttpEngine(Environment env) { + int port = Integer.parseInt(env.getProperty("server.port", "8080")); + return new SpringBootPlatformHttpEngine(port); } @Bean diff --git a/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpEngine.java b/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpEngine.java index 5e589367509..0e99fd19a60 100644 --- a/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpEngine.java +++ b/components-starter/camel-platform-http-starter/src/main/java/org/apache/camel/component/platform/http/springboot/SpringBootPlatformHttpEngine.java @@ -23,9 +23,19 @@ import org.apache.camel.component.platform.http.spi.PlatformHttpEngine; public class SpringBootPlatformHttpEngine implements PlatformHttpEngine { + private final int port; + + public SpringBootPlatformHttpEngine(int port) { + this.port = port; + } + @Override public Consumer createConsumer(PlatformHttpEndpoint endpoint, Processor processor) { return new SpringBootPlatformHttpConsumer(endpoint, processor); } + @Override + public int getServerPort() { + return port; + } }