[rabbitmq-discuss] producer/consumer and every n-th message

Fri Jul 8 00:03:24 BST 2011

Hey,

Let's say I have n producers sending messages to an exchange and m
consumers consuming from a single queue bound to that exchange. When a
consumer does not acknowledges a message (and dies), the message
should go back into the queue for another consumer to pick it up.

That should be easy to implement I assume?
I also assume for this scenario a direct exchange would do?
How bad would be the contention n and m are fairly large?
...or do I just need to have enough broker?

I would also like to be able to "tap into" the stream of messages
flowing through the exchange. I assume I could use a fanout exchange
instead. Have the normal queue with the m consumers and a second queue
with a single consumer "tapping in".

As the throughput of message can potentially be very high (which is
why there are so many consumers) of course a single consumer cannot
drain the second queue. So my idea was to only care about every n-th
message.

Is there a away to tell the fanout consumer to deliver every message
to Q1 but only every 10th message to Q2?
How else could one do this?

cheers,
Torsten