2010-04-19 38 views
2

我有一个消息路由来实现,它具有根据消息内容而变化的路由。该路线的一些线路依赖于其他线路。ActiveMQ&Camel - 如何在路由路径中创建依赖

如果例如我有Data_A其中有Task_A和Task_B在它上执行。 而Data_B只有Task_B在其上执行。

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

如果Task_A只能在Task_B之后执行,如果对数据请求了Task_B,那么我该如何设置这种依赖关系?

回答

4

您可以使用多种途径分支出来的工作流程,这样

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");