Sorry for confusion..I just debugged inside that
GroupedExchangeAggregationStrategy to see what newExchange value
has..Anyways in order to avoid confusion i created a dummy one..But still
the problem persists...
public class MyAggregationStrategy implements AggregationStrategy {
@Override
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
return null; //To change body of implemented methods use File |
Settings | File Templates.
}
}
and this is my route
from("direct:getlivestreaminfo").startupOrder(2).convertBodyTo(String.class)
.recipientList().method(messageRouter,
"routeTo").parallelProcessing().aggregationStrategy(new
MyAggregationStrategy())
.process(eventStreamedProcessor).to("log:foo");
--
View this message in context:
http://camel.465427.n5.nabble.com/Converting-message-body-after-GroupedExchangeAggregationStrategy-tp5158191p5160748.html
Sent from the Camel - Users mailing list archive at Nabble.com.
