Collect from activemq in one transaction with Apache Camel

Question

What I like to do:

1. Listen and get messages from a queue in one transaction.
2. Filter and collect the messages.
3. When a specific number of messages is received or a timeout they should be sent to another queue. The transaction should be committed when they are successfully transferred to next queue.

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?

question from:https://stackoverflow.com/questions/65841890/collect-from-activemq-in-one-transaction-with-apache-camel

Answer 1

Waitting for answers