Hi!
I am trying to use the Throttle pattern to satisfy an SLA. The situation is
that I must send messages to a provider but I can not send messages faster
than a SLA defined rate. The process that sends messages to the provider
reads from an activemq queue so route this queue to another, set a Throttle
with the SLA rate between the original queue and the new one and make the
process read from these new queue.
The problem is that if the consumer process crash and is restarted, it
founds many messages in the queue, as the throttle continues to move
messages between the queues at the specified rate. The process then sends
all these messages, violating the SLA.
Is there a way of preventing the throttle of continuing putting messages in
the queue unless they are being consumed?
Thanks in advance for your help. I am quite new to Camel, so sorry if the
question is too obvious.
--
View this message in context:
http://www.nabble.com/Blocking-throttle-tp25373167p25373167.html
Sent from the Camel - Users (activemq) mailing list archive at Nabble.com.
