动态“自”endpoint和交换在camel中如何工作？

Question

我有点纠结于动态路由概念和消费者规则。

假设我有一个带有交换数据的路由，然后我想在“从”endpoint的不同路由中使用来自交换的报头。

我想它看起来是这样的：

一号干线：

from("file:/dir1")
...
.to ("direct:start");

二号干线：

from("direct: start")//get the old exchange data
.from("file:/dir1/?fileName=${header.myHeader}")//start consuming from a different endpoint using old exchange data
...
.to("direct: end);

所以这些步骤对我来说似乎是正确的，但我觉得我有点污染了交流。

对我来说，我使用动态路由，但同时也创造了一个新的消费者。这意味着我要创建一个新的交易所，对吗？那么，骆驼如何知道在剩下的路线中选择和使用哪种交换呢？

起初我认为它可能将它们结合在一起，但我做了更多的挖掘，发现你实际上需要使用“丰富”来添加到现有的交换中。

有人能解释一下骆驼是如何处理这种情况的吗？如果你有一个很好的例子。我在骆驼包里找了一个，但没有成功。

Answer 1

您可以使用内容丰富模式实现“动态自”。

假设您的第一个路由用于将文件名添加到头文件中，例如：

from("timer:trigger?repeatCount=1")
.routeId("define-file-name")
.setHeader("myHeader", constant("file.txt"))
.to("direct:start");

然后，您的第二个路由可以像这样使用来自交换头的信息轮询该文件。

from("direct:start")
.routeId("poll-file")
.pollEnrich().simple("file://dir1?fileName=${in.header.myHeader}").timeout(10000)
.log("${body}");