activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Gary Tully <>
Subject Re: Change of email distribution to consumers
Date Mon, 24 May 2010 13:25:05 GMT
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 ( 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 (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 <> 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:
> Sent from the ActiveMQ - User mailing list archive at


Open Source Integration

  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message