【问题标题】:ActiveMQ & Camel - How to create dependency in routing pathsActiveMQ & Camel - 如何在路由路径中创建依赖关系
【发布时间】:2011-02-09 20:08:06
【问题描述】:
我有一个消息路由要实现,它的路由会根据消息内容而变化。路线的某些部分依赖于其他部分。
例如,如果我有 Data_A,其中有要执行的 Task_A 和 Task_B。
而 Data_B 只需要对它执行 Task_B。
这里每个任务都有一个由消费者服务的队列。
如果对数据请求Task_B,则Task_A只能在Task_B之后执行,我该如何设置这样的依赖关系?
【问题讨论】:
标签:
java
jms
activemq
amqp
apache-camel
【解决方案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");