ApacheCamel聚合器InOut应答

Question

我试图在聚合器完成后获得一个回复，但是我得到一个异常，我没有指定任何聚合器子项，但是当我指定一个。to（）endpoint我没有收到聚合结果。。。这可能吗？

控制器：

@SpringBootApplication
@RestController
public class App {
@Produce(uri = "direct:intake")
private ProducerTemplate producerTemplate;

public static void main(final String...args) {
    SpringApplication.run(App.class, args);
}

@RequestMapping("/test/{message}")
public String test(@PathVariable String message) {
    return this.producerTemplate.requestBodyAndHeader("direct:intake", message, "id", "abc123").toString();
}
}

聚合器：

@Component
public class Aggregator extends RouteBuilder {

@Override
public void configure() throws Exception {
    from("direct:intake")
            .aggregate(header("id"))
            .aggregationStrategy(new AggregationStrategy() {
                @Override
                public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
                    if (oldExchange == null)
                        return newExchange;
                    oldExchange.getIn().setBody(oldExchange.getIn().getBody() + "::" + newExchange.getIn().getBody());
                    return oldExchange;
                }
            })
            .completionTimeout(5000)
            .to("stream:out");

}
}

Answer 1

推特上有人好心让我知道聚合器完成的交换不会在回复中返回。