No..The body inside that exchange is of type
org.apache.camel.converter.stream.CachedOutputStream$WrappedInputStream@4b8b7245
And when i just debug it inside GroupedExchangeAggregationStrategy and
evaluate newexchange using
newExchange.getIn().getBody(String.class),its returning empty string.("")
So either the conversion isnt working or the stream is closed at that point?
This is my route
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-tp5158191p5160728.html
Sent from the Camel - Users mailing list archive at Nabble.com.