I would like to be able to change the throttle value dynamically based on a
some setting.
I have created a bean that returns this value, so it basically looks like
this.
def.throttle(bean("applicationService",
"getApplicationChannelQuota")).timePeriodMillis(DAY_IN_MILLI_SECONDS)
We are essentially using it to manage a daily quota of messages, which I
understand it is not essentialy what it was designed for, but the
functionality is much the same.
The problem is that if we hit the limit, the message is throttled and stays
inflight. This means that we we change the quota to a higher value then that
message still remains at the lower value and as such the messages are not
released.
I have tried to stop and start the route, but this doesnt seem to clear the
message (should it?), only restarting the whole application seems to clear
things up.
Is there a way to do this or would we have to implement our own way of doing
quotas?
regards
Antony
--
View this message in context:
http://camel.465427.n5.nabble.com/Unable-to-change-throttle-with-inflight-messages-tp4760204p4760204.html
Sent from the Camel - Users mailing list archive at Nabble.com.
