我有一个使用Camel jetty组件作为网关的带有Camelendpoint路由的Spring Boot应用程序。
@Component
public class StartEcommerce extends RouteBuilder {
@Override
public void configure() throws Exception {
restConfiguration()
.host("localhost")
.port(8085);
rest("/rest/v1")
.post("/order")
.to("direct:ecommerceRestRoute")
.post("/cancelEnrollment")
.to("direct:cancelEnrollmentRestRoute");
// other routes ...
}
}
如果我将jetty组件放在端口8085中执行,那么一切都可以正常工作。
localhost:8081/health
localhost:8081/rest/v1/order
localhost:8081/rest/v1/cancelEnrollment
我试图跟踪这场讨论
使用Spring Boot中的现有http服务器作为骆驼endpoint
但我得到了下面的错误,因为我有两个Jetty运行在同一个端口上
***************************
APPLICATION FAILED TO START
***************************
Description:
Embedded servlet container failed to start. Port 8081 was already in use.
Action:
Identify and stop the process that's listening on port 8081 or configure this application to listen on another port.
我使用的是Camel-Jetty2.18.0一个Spring Boot1.4.2.版本。
有什么建议我怎样才能做到这一点?
我找到了解决方案,我的build.gradle中有一个不正确的依赖项集。
compile('org.apache.camel:camel-jetty:2.18.0')
此外,我从路由中删除rest配置:
restConfiguration()
.host("localhost")
.port(8081);
以克劳斯·易卜生为例
(我在命中RESTendpoint时有)。 如何正确设置焊接(最好是编程方式)?
我有哪些选项可以将Kafka与Spring靴骆驼连接? 我正在运行ActiveMQ Artemis和Camel,以建立进出客户端的JMS/MQTT和REST路由。我想把Kafka添加到这个二重唱中,以流式传输/交换数据(视频音频、文件/文本)。 到目前为止,我下载了Kafka汇合平台(免费试用),我正在测试他们提供什么。在融合平台中,我看到有可能将连接器作为“插件”添加。我假设我可以添加Camel
没有“org.apache.camel.CamelContext”类型的合格bean可用:应至少有一个合格的自带候选bean。 依赖项注释:{@org.SpringFramework.Beans.Factory.Annotation.AutoWired(required=true)}
我在spock和groovy的初始阶段,我试图测试一个简单的Spring启动应用程序,并获得 下面是我的java和groovy代码以及异常详细信息 TestController.java TestControllerSpec。棒极了 我确信我的代码遗漏了什么
我有一个Spring Boot2.25.1应用程序,它使用Camel 2.25.1与camel-kafka,一切都正常工作…在我的Kafka消费者中,我需要添加该功能以按需暂停消费,因此我升级到camel 3.18.1,以便我可以使用可暂停功能。升级到3.18.1后,我收到错误FileNotes与类文件TimeoutAwareAggregationStategy.class. 当我打开camel-
因此,如果我向安全系统没有侦听的URL发出请求,则设置CORS头。Spring SecurityURL-未设置。 Spring靴1.4.1