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

Question

我正在尝试使用Apache Camel 3endpointDSL。这是我目前的代码。它工作正常。这是一个测试，所以非常简单。它从目录中读取并记录文件内容。

@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 String componentName=“myCustomFileComponent”；

我在控制台中遇到以下错误

Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: myCustomFileComponent:///in/ due to: No component found with scheme: myCustomFileComponent

从这里，我了解到我可以为示例中的endpointmyWMQ和myAMQ提供自定义名称。例如，路由从一个目录读取，然后写入另一个目录，我希望每个组件都以不同的方式配置。但是如果我指定了一个自定义组件名，我就会得到错误。因为它找不到custonName组件。

我不知道它是否相关，但代码在Spring Boot项目中

• Apache Camel版本3.4.0 Spring Boot版本2.3.1

Answer 1

似乎你没有抓住重点。该部分解释了“是否有多个相同类型的Camel组件注册了不同的名称”。这些是注册不是endpointuri的camel组件。

据我所知，在apache camel中不能有动态路由endpoint，因为路由是在开始时创建的，并且这些endpoint在运行时不会更改。

如果你需要一个从不同endpoint读取数据的路由，你可以做的是为它们设置路由，并将它们路由到相同的endpoint，比如：

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}");
    }

}