java - Camel同步路由以recipientList启动异步路由

Question

这是我路线的起点:

from("direct:initRoute").routeId("initRoute")
            .log("Start route")
            .beanRef("routeProcessor","extractProcessor")
            .validate().method("fileProcessor","valid")
            .beanRef("routeProcessor","initData")
            .beanRef("routeProcessor", "choiceSendTo")
            .recipientList(header("sendTo"));

然后根据 Exchange 中存在的数据启动其他路由。

我同步调用此路由，如下所示:

ProducerTemplate template = camelContext.createProducerTemplate();
ExchangeBuilder exchangeBuilder = new ExchangeBuilder(camelContext);
// Code that setup the exchange.
LOGGER.error("BEFORE");
template.send("direct:initTraitement", exchangeBuilder.build());            
LOGGER.error("AFTER");

我期望日志中出现以下输出:

- BEFORE
- DATA INIT LOGS
- AFTER
- **RECIPIENTS ROUTES LOGS**

但是我得到了这个:

- BEFORE
- DATA INIT LOGS
- **RECIPIENTS ROUTES LOGS**
- AFTER

我认为路由是独立的，所以如果我同步向路由发送请求，我会在该路由完成后立即收到回复。但显然，整个过程(所有连接的路由)都是在我的其余代码运行之前执行的。

我希望在调用 recipientList() 后继续执行我的代码。我怎样才能实现这个目标？

我尝试在 recipientList() 之后使用 parallelProcessing()，如 documentation 中所述。但这并不能解决我的问题。

编辑:我需要同步启动第一条路线。仅当 initData 函数完成其工作时，代码才必须运行。以下路由应该是异步的。

Answer 1

并行处理只是意味着，如果您向收件人列表提供多个端点，这些端点将被并行处理。请参阅并行处理文档:

Camel 2.2: If enabled, messages are sent to the recipients concurrently. Note that the calling thread will still wait until all messages have been fully processed before it continues; it's the sending and processing of replies from recipients which happens in parallel.

如果您想使用 ProducerTemplate 执行路由并且不想等到路由完成，则必须使用例如 asynSend 方法而不是 send 方法。

另一种可能性是确保 sendTo header 配置有异步端点(例如 seda)。

更多信息由camel文档提供，例如http://camel.apache.org/asynchronous-processing.html

亲切的问候，土壤 worker