Camel route是从java激活的——如何从最后一条路由获得响应

Question

从我使用camel的spring boot中，我想知道当完成camel路由时（我的示例中的最后一条路由），是否有可能从camel路由获得响应。它开始像这样使用ProducerTemplate：

@Component
public class CamelSender {

@Produce(uri = "direct:start")
private ProducerTemplate template;

public void callRoute(List<String> list) throws ExecutionException, InterruptedException {
    template.sendBodyAndHeader("direct:start", list, "orderId", "123456677"
    );
}
}

//骆驼路线

from("direct:start")
    .log("Split -> Process order ${body}")
    .split().body().to("direct:actionQueue") 
    .end();

 from("direct:actionQueue")
    .bean(ValidateOrders.class)
    .log("Sending to join queue")
    .to("direct:joinQueue");

 from("direct:joinQueue").aggregate(new MyOrderAggregationStrategy())
    .header("orderId")
    .completionTimeout(1000L)
    .process(new Processor() {
        @Override
        public void process(Exchange exchange) throws Exception {
                    List<String> orders =   (  (List<String>)  exchange.getIn().getBody());
                    String collect = orders.stream().map(order -> order.toString()).collect(Collectors.joining(","));
                    exchange.getIn().setBody( "Collected validations: "+collect);
                }
            })
            .log("${body}");

如何将包含收集的验证（字符串）的正文返回给我的JavaBean？

Answer 1

使用复合消息处理器EIP，而不是拆分聚合。因为后者是两个独立的进程，聚合器的输出不能作为响应发送回拆分器。前者可以通过使用拆分器中的内置聚合策略来实现。

您可以在Camel EIP上找到示例和更多详细信息-请参阅拆分器仅示例：http://camel.apache.org/composed-message-processor.html