I tried this but no luck...In my receipient list,the list of recipients are a
comma separated HTTP URLs..
So what iam trying to do is make a parallel request to bunch of HTTP urls
and than try to process them in the
processor(eventStreamedAggregationProcessor).Inside that processor, i
retrieve list of exchanges but the body in each of them are of type
org.apache.camel.converter.stream.CachedOutputStream$WrappedInputStream.
And sometimes i can see that the stream is closed as well.
from("direct:getlivestreaminfo").startupOrder(2).convertBodyTo(String.class)
.recipientList().method(messageRouter,
"routeTo").parallelProcessing().aggregationStrategy(new
GroupedExchangeAggregationStrategy())
.process(eventStreamedAggregationProcessor).to("log:foo");
--
View this message in context:
http://camel.465427.n5.nabble.com/Converting-message-body-after-GroupedExchangeAggregationStrategy-tp5158191p5160681.html
Sent from the Camel - Users mailing list archive at Nabble.com.
