What I like to do:
What I came up with:
from("activemq:queue:collect?transacted=true") .transacted() .aggregate(new FilterAndCollectAggregationStrategy()) .completionInterval(10000L) .completionSize(1000) .to("activemq:queue:process");
And the problem: A new transaction is created for each message and are automatically committed when sent to the aggregator. How to get one transaction for all messages that is committed when sent to the "process" queue?
1.4m articles
1.4m replys
5 comments
56.9k users