2
我有一个消息路由来实现,它具有根据消息内容而变化的路由。该路线的一些线路依赖于其他线路。ActiveMQ&Camel - 如何在路由路径中创建依赖
如果例如我有Data_A其中有Task_A和Task_B在它上执行。 而Data_B只有Task_B在其上执行。
这里每个任务都有一个消费者服务的队列。
如果Task_A只能在Task_B之后执行,如果对数据请求了Task_B,那么我该如何设置这种依赖关系?
我有一个消息路由来实现,它具有根据消息内容而变化的路由。该路线的一些线路依赖于其他线路。ActiveMQ&Camel - 如何在路由路径中创建依赖
如果例如我有Data_A其中有Task_A和Task_B在它上执行。 而Data_B只有Task_B在其上执行。
这里每个任务都有一个消费者服务的队列。
如果Task_A只能在Task_B之后执行,如果对数据请求了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");