camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From suman <prashanth.shivaku...@gmail.com>
Subject Re: Converting message body after GroupedExchangeAggregationStrategy
Date Fri, 20 Jan 2012 15:27:10 GMT
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.

Mime
View raw message