Apache Camel:在由Camel route调用的bean方法中获取消费者endpoint信息

Question

我有多个数据库，都包含同一个表Data。我想从中读取，将所有Data元素输入到MyBean方法@Handler public Data updateData（Data Data）中，并写回该方法的输出。

from("jpa://Data?persistenceUnit=persUnit1").to("direct:collector");
from("jpa://Data?persistenceUnit=persUnit2").to("direct:collector");
from("jpa://Data?persistenceUnit=persUnit3").to("direct:collector");
...

from("direct:collector").bean(new MyBean()).to("jpa://Data?persistenceUnit=destinationUnit");

然而，我需要bean中Data元素来自哪个源的信息（例如持久性单元的名称）以进行验证。最好的方法是什么？

Answer 1

exchange对象提供有关（当前交换的）“from”endpoint的必要信息：

https://www.javadoc.io/doc/org.apache.camel/camel-api/latest/org/apache/camel/Exchange.html#getFromRouteId（）

将id放在路由上是很常见的（但也在endpoint上）

from("jpa://Data?persistenceUnit=persUnit1")
  .routeId("ComingFromRouteA")
  .to("direct:collector");

这样，你可以知道你来自哪里，使用：

exchange.getFromRouteId()

Answer 2

你可以设置一个标题

from("jpa://Data?persistenceUnit=persUnit1")
    .setHeader("dataSource", constant("dataSource1"))
    .to("direct:collector");
from("jpa://Data?persistenceUnit=persUnit2")
    .setHeader("dataSource", constant("dataSource2"))
    .to("direct:collector");