我正在尝试使用Apache 3 端点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但是当我试图更改组件的名称时。例如,最终字符串componentName = "myCustomFileComponent";
我在控制台中得到以下错误
Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint: myCustomFileComponent:///in/ due to: No component found with scheme: myCustomFileComponent通过这里,我了解到我可以为示例中的端点、myWMQ和myAMQ提供自定义名称。例如,路由从一个目录读取并写入另一个目录,我希望以不同的方式配置每个组件。但是,如果我指定了一个自定义componentName,我就会得到错误。因为它找不到custonName组件。
我不知道它是否相关,但是代码在Spring项目中
发布于 2020-07-01 08:04:46
看来你没抓住重点。这一节解释了“同一类型的多个骆驼部件是否以不同的名称注册”。这些是camel组件,注册的不是端点的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}");
}
}https://stackoverflow.com/questions/62658362
复制相似问题