camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gtesta13 <gtest...@gmail.com>
Subject Problem With Camel Aggregator
Date Tue, 30 Oct 2012 01:59:25 GMT
Hi,
I have a route that looks like this:

from("cxf:bean:personasEndpoint").to("ReqPreProcessor").to("seda:a?multipleConsumers=true");
from("seda:a").to("CXFProcessor1").to("cxf:bean:Consulta1Service").to("direct:b");
from("seda:a").to("CXFProcessor2").to("jdbc:pgDS").to("direct:b");
from("direct:b").aggregate(header("idReq"), new AggregationStrategyPersona()
).completionSize(2);

I tried to do is to collect the bodies of the messages in one.
In the RePreProcessor I do this:

exchange.getOut().setHeaders(exchange.getIn().getHeaders());
                exchange.getOut().setHeader("idReq", "1");
                exchange.getOut().setBody(exchange.getIn().getBody());

I did this to try to use the agregattor....Is this right? And also giving me
the following error:

org.apache.camel.FailedToCreateRouteException: Failed to create route route4
at: >>> Aggregate[header{idReq} -> []] <<< in route: Route[[From[direct:b]]
-> [Aggregate[header{idReq} -> []]]] because of Definition has no children
on Aggregate[header{idReq} -> []]
       
Can anyone help me with this?

Thanks

Gaston 



--
View this message in context: http://camel.465427.n5.nabble.com/Problem-With-Camel-Aggregator-tp5721756.html
Sent from the Camel - Users mailing list archive at Nabble.com.

Mime
View raw message