orked around with backups).
Hope that helps, not sure if I would know of any other ways how to achieve what
you're looking for.
Regards,
Valdis
-Original Message-
From: Peter Billen [mailto:peter.bil...@gmail.com]
Sent: 19 December 2018 13:07
To: users@camel.apache.org
Subject: Re: How
Hi Valid, Camelers,
I got the required parallelism working with dynamic routing and seda queues
as following:
from("rabbitmq://localhost?username=test&password=test&declare=false&queue=q&autoAck=false&threadPoolSize=1")
.process(exchange -> exchange.getIn().setHeader("queue",
exchange.ge
Hi Valdis,
Many thanks for your feedback, appreciate it.
I believe I was looking for the static or dyanamic routing:
- Aggregation is not suitable for my use case, as I don't have a
deterministic message flow. I also want to process messages in a real-time
manner.
- Static/dynamic message
Hi Peter,
Given you have a header already identifying the message categories, you could
try to look into the Aggregator EIP:
http://camel.apache.org/aggregator2.html
It will allow you to group all the messages by the header into 'batches' for
each of the groups. Each batch can then be processe
