Hi!
I'm in trouble with aggregator please have a look the following route!
from("jms:queue.purse.in")
.choice()
.when(new PredicateMessage()).to("direct:aggregate")
.process(new ContextRequestProcessor())
.to("jms:queue.access.in").to("direct:aggregate").to("jms:queue:dummy")
.otherwise()
.to("ejb:Diad/DiadPurseRouteProxy/local?method=processPurse");
from("direct:aggregate")
.aggregate(simple("${header.breadcrumbId}"), new
BodyInAggregatingStrategy()).completionSize(2)
.to("ejb:Diad/DiadPurseRouteProxy/local?method=processPurse").to("bean:computeDestination").to("jms:queue:answer");
I only want the result of aggregate to return to the replyto queue
associated with queue.purse.in.
Aggregate is success but the result of the queue.access.in returns?!
I need the result of the ("jms:queue.access.in") therefore I can't set to
inonly this queue call.
Now you can see one workaround:
1. sending the result of queue.access.in to one of dummy queue
2. at the end of the aggregate setting the replyto explicitly to the
original replyto to and send the message back explicitly.
How can I send back only the result of the aggregate? How can I drop a
message after processing it in case of inout exhangepattern?
Thanks!
topicfun
--
View this message in context:
http://camel.465427.n5.nabble.com/Aggregator-design-tp5620132p5620132.html
Sent from the Camel - Users mailing list archive at Nabble.com.
