Hi,
I'm trying to work out how to use Camel to do the following:
For efficiency reasons I want my main Processor to work on all messages
received in the last 10 seconds. Messages will be send over HTTP (or JMS
going forward)from multiple endpoints using the InOut exchange pattern. I
want to collect them all together, present a list of the 'bodies' to a
processor and then have it return a list of responses. Each response then
needs to be matched to the relevant request and a reply generated to the
corresponding queue.
I've tied using the route sequence:
from("jetty:http://localhost1234/munge?matchOnUriPrefix=true";)
.aggregate(constant(true))
.completionTimeout(5000L)
.groupExchanges()
.process(myClass)'
but my producers seem to get a response immediately to their input message.
The timeout then fires and my processor get the list but the results don't
go anywhere.
Before I either dig deeper or give up I wondered if a guru out there could
tell me if this is possible in Camel. Its very similar to examples but none
of the ones I've looked at have the InOut pattern.
Thanks
Nigel
--
View this message in context:
http://camel.465427.n5.nabble.com/How-to-do-aggregation-of-multiple-InOut-exchanges-from-different-producers-tp5741621.html
Sent from the Camel - Users mailing list archive at Nabble.com.
