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 <[email protected]>
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;
+ }
}