apache-camel - 动态拦截 Camel 端点

Question

我正在尝试拦截 URI 的值与交换 header 中的某些信息匹配的端点。

假设我在 header 中有一个名为 DatabaseName 的字段。我想强制执行特定路由仅写入 header 中指定的数据库。

我可以做这样的事情吗？

interceptSendToEndpoint("mock:${in.header.DatabaseName}")

我试过了，但是好像不行。我有哪些选择？

我也在考虑做这样的事情:

interceptSendToEndpoint("mock:*").when(...)?

但在这种情况下，我不确定我是否可以在when表达式中引用被拦截节点的URI。

谢谢

Answer 1

您可以使用通配符进行拦截，并将其与何时执行您想要的操作相结合，详情请参阅:http://camel.apache.org/intercept

消息上的 header 具有键 Exchange.INTERCEPTED_ENDPOINT (CamelInterceptedEndpoint)，它具有被拦截的端点 uri。您可以在 when 中使用它来匹配谓词。类似的东西:

interceptSendToEndpoint("mock:*")
  .when(simple("${header.CamelInterceptedEndpoint} == ${in.header.DatabaseName}"))
  ...