Apache Camel Endpoint-dsl 自定义组件名称



我正在尝试使用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

从这里,我知道我可以为示例中的端点myWMQmyAMQ提供自定义名称。例如,路由从一个目录读取并写入另一个目录,我希望每个组件都以不同的方式配置。但是,如果我指定自定义组件名称,则会出现错误。因为它找不到 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}");
}
}

最新更新