On Fri, Jan 20, 2012 at 4:22 PM, suman <[email protected]> wrote:
> 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
>
As I told you do NOT use the GroupedExchangeAggregationStrategy.
Build your custom strategy and convert the payload to a String.
> 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.
--
Claus Ibsen
-----------------
FuseSource
Email: [email protected]
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/
