You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@camel.apache.org by garybarker <ga...@first-utility.com> on 2016/07/15 10:39:13 UTC
Queue batching solution
Is there a good camel way to batch requests for multiple types appearing on a
queue?
For instance I wish to listen on an AMQ queue for all events and then after
an event limit, or a timeout, we forward on the separate batches as a list
to a rest service. Something like:
from(fromEndpoint).routeId(ROUTE_ID)
.aggregate(constant("batch"), new
EventTypeAggregationStrategy())
.completionSize(1000)
.completionInterval(3600000)
.beanRef("eventAdaptorClient", "send")
.end();
Is it then possible to hold those messages for, say, an hour without
committing them (or losing them on a failure), or would a different solution
be preferable?
--
View this message in context: http://camel.465427.n5.nabble.com/Queue-batching-solution-tp5785147.html
Sent from the Camel - Users mailing list archive at Nabble.com.