Erlang Mailing Lists

On Thu, Oct 15, 2009 at 01:28, Colin Z <theczintheroc2007@gmail.com (theczintheroc2007@gmail.com)> wrote:
> If I have a queue with multiple subscribers/consumers and it also requires
> acks for the messages, what is the resulting behavior?
>
> Will the queue round robin the messages out to the subscribers regardless of
> whether the messages have been ack'ed yet or not? Or will the first message
> basically stall the delivery of the other messages in the queue until the
> first message has been ack'ed?



By default, if you have two consumers that are reading from one
queue, they will receive exactly every second message. No matter
if the messages were "light" or "heavy". For example, if queue looks like:
[light, heavy, light, heavy, light, heavy]
The first consumer will get all the "light" messages, and the second
one will get all the "heavy" ones. No matter when they will be acknowledged.
See this code:
http://ai.pjwstk.edu.pl/~majek/dump/qos_no.py


Basic.qos is used to fight this limitation. Using it you can specify
how many messages are allowed to be unacknowledged for a channel.
Here you can see how to use it:
http://ai.pjwstk.edu.pl/~majek/dump/qos_yes.py

Cheers!