我正在尝试使用Apache Camel 3 Endpoint DSL。这是我到目前为止的代码。它工作正常。这是一个测试,所以它真的很简单。它从目录中读取并记录文件内容。
@Component
public class TestRoute extends EndpointRouteBuilder{
final String componentName = "file";
final String path = "/in/";
@Override
public void configure() throws Exception {
FileEndpointBuilder srcFileEndpoint = file(componentName, path);
from( srcFileEndpoint ).log(LoggingLevel.INFO, "body, ${body}");
}//configure
}//TestRoute
但是当我尝试更改组件的名称时。例如 final 字符串组件名称 = "myCustomFileComponent";
我在控制台中收到以下错误
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: myCustomFileComponent:///in/ due to: No component found with scheme: myCustomFileComponent
从这里,我知道我可以为示例中的端点myWMQ和myAMQ提供自定义名称。例如,路由从一个目录读取并写入另一个目录,我希望每个组件都以不同的方式配置。但是,如果我指定自定义组件名称,则会出现错误。因为它找不到 custonName 组件。
我不知道它是否相关,但代码在 Spring 启动项目中
- Apache Camel版本3.4.0 Spring Boot version 2.3.1
看来你没有抓住重点。该部分解释了"同一类型的多个骆驼组件是否以不同的名称注册"。这些是注册的驼峰组件,而不是端点的 uri。
据我所知,你不能在 apache Camel 中拥有动态路由端点,因为路由是在开始时创建的,并且这些端点在运行时不会更改。
如果您需要一个从不同端点读取的路由,您可以做的是为它们提供路由并将其路由到同一端点,例如:
public class TestRoute extends RouteBuilder {
@Override
public void configure() {
from(component1)
.to("direct:myroute")
from(component2)
.to("direct:myroute")
from(component3)
.to("direct:myroute")
from("direct:myroute")
.log(LoggingLevel.INFO, "body, ${body}");
}
}