On 01/16/2014 07:20 PM, Helen Kwong wrote:
Hi Qpid users / experts,
I need to limit the number of consumers concurrently processing messages
considered to be in the same group, across multiple queues, and was
wondering if anyone has ideas about how to do it. We’re using the Java
broker and client, and have multiple queues, each with multiple listeners,
each listener’s session listening to multiple queues. Some messages are
associated with groups, and for a given group we want at most K listeners
processing messages from the group at any given time. The messages are
enqueued to multiple queues, and it’s possible for messages from the same
group to be in different queues.
If messages in the same group can go into only one queue, then the message
groups feature will give us what we need (it’d work directly with K = 1 and
with K > 1 we can tweak the grouping value, e.g., hash it to one of 1 to K
and append the number to the grouping value). But since messages considered
to be in the same group can be in different queues, the feature is not
enough for our case.
Instead of multiple queues, could you have one queue with different
selectors pulling subsets of the messages?
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
