Camel requestBodyAndHeaders() doesn't return the route result -
i have camel route split/aggregate:
from("seda:start") .routeid("camelroute") .log("request: ${body}") .split() .method(splitservice.class, "splitrequest") .parallelprocessing() .bean(sendtoworker.class, "sendtoq1(${body}, ${headers})") .aggregate(header("corrid"), new customaggregationstrategy()).completionsize(5) .log("aggregated ${body}") .bean(sendtoworker.class, "sendtoq2(${body}, ${headers})") .log("response: ${body}");
the last log displays result correctly. when call as
@autowired private producertemplate producertemplate; [...] object o = producertemplate.requestbodyandheaders("seda:start", request, headers)
i'm not able result camel route. the returned o instance request object itself.
does have idea can wrong here?
thanks help.
you should use splitter agg strategy split + aggregate, done in same leg.
see split aggregate request/reply sample at:
Comments
Post a Comment