|
@@ -148,8 +148,15 @@ public class Route extends ExceptionHandlerBaseRoute {
|
|
|
Object temp = exchange.getIn().getBody();
|
|
|
exchange.setProperty("tempBody",temp);
|
|
|
})
|
|
|
- .to(Const.venders+"/auxiliary/vender/query_detail").
|
|
|
- process(new VenderMapProcessor());
|
|
|
+ .to(Const.venders+"/auxiliary/vender/query_detail")
|
|
|
+ .process(new VenderMapProcessor())
|
|
|
+ .split(body(), (oldmsg, newmsg) -> {
|
|
|
+ if(oldmsg == null){
|
|
|
+ return newmsg;
|
|
|
+ }
|
|
|
+ oldmsg.getIn().setBody(oldmsg.getIn().getBody(String.class) + newmsg.getIn().getBody(String.class));
|
|
|
+ return oldmsg;
|
|
|
+ }).parallelProcessing().parallelAggregate().to("direct://test");
|
|
|
}
|
|
|
|
|
|
|