我有一个消息路由要实现,它的路由根据消息内容而变化。路线的某些部分依赖于其他部分。
例如,如果我有 Data_A,其中要执行 Task_A 和 Task_B。 而 Data_B 只需要执行 Task_B。
这里每个任务都有一个由消费者服务的队列。
如果在数据上请求 Task_B 时,Task_A 只能在 Task_B 之后执行,那么如何设置此类依赖关系?
最佳答案
您可以使用多个路线来分支工作流程,如下所示
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");
关于java - ActiveMQ 和 Camel - 如何在路由路径中创建依赖关系,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/2670133/