ActiveMQ 与Camel - 如何在路由路径中创建依赖关系

Question

我有一个要实现的消息路由，它的路由根据消息内容而变化。路线的某些部分依赖于其他部分。

例如，如果我有 Data_A，其中有 Task_A 和 Task_B 要对其执行。 而 Data_B 只需要执行 Task_B。

这里每个任务都有一个由消费者服务的队列。

如果在数据上请求 Task_B 时，Task_A 仅应在 Task_B 之后执行，那么如何设置此类依赖关系？

Answer 1

您可以使用多个路线来分支工作流程，如下所示

from("queue:start").
  choice().xpath("//foo")).to("queue:taskB").
  otherwise().to("queue:taskA");

from("queue:taskB").process(new DoTaskB()).to("queue:taskA");

from("queue:taskA").process(new DoTaskA()).to("queue:done");