There is a "strictOrderDispatch" attribute that changes the dispatch algorithm for queues, a consumer will continue to get messages till its prefetch is reached. It is set via a destination policy.
In addition, there is a new "usePrefetchExtension" attribute that ensures that a message will only be delivered to a transacted consumer when it predecessor is acked rather than delivered. This attribute ( https://issues.apache.org/activemq/browse/AMQ-2651) is only available on trunk (or a 5.4 snapshot) atm. You may also be interested in the the camel based solution to redelivery processing from https://issues.apache.org/activemq/browse/AMQ-2710 (see the subversion commit tab to see the source). You can build the delay into camel pending the scheduled delivery feature in 5.4. On 24 May 2010 13:00, Pavel Moravec <pavel.mora...@acision.com> wrote: > > Hello, per my experience ActiveMQ puts incoming emails into particular > consumers "queues" on round robin basis. I.e. having 50 consumers for one > ActiveMQ queue, every 50th email is sent to one particular consumer, > regardless the responses received from the customers. > > My question is: is it possible to change this load strategy according to > e.g. number of mails pending to each consumer? > > Some background: Due to some reason, we have prefetch set to 1 and retry > mechanism re-delivering a temporarily rejected email for approx. 13 minutes > until the email goes to DLQ. For that time, emails routed towards this > consumer are being buffered. What is not desireable, to have 13 minutes > delay due to one email being steadily temporarily rejected. > > Therefore it would be worth for us to have some another loading strategy > that will select the consumer with the least number of pending emails to > that consumer. Is this strategy available? If so, how to set it up? > > Thanks in advance for any hint and apologize for the gritty style of my > topic description. > -- > View this message in context: > http://old.nabble.com/Change-of-email-distribution-to-consumers-tp28656134p28656134.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- http://blog.garytully.com Open Source Integration http://fusesource.com
