[rabbitmq-discuss] RabbitMQ persistence and multi producers- multi consumers

Fri Jul 9 12:56:50 BST 2010

On 09/07/10 12:49, Francisco Gonzalez-Blanch wrote:
> Thanks for the answers!  But If the producer is launched first and then
> the consumer, i'm losing all the initial messages until the consumer is
> created. I attach you the code snippets with the test.

I think contrary to what Andreas said, in your case you should have the 
producer create a queue with a well known name when it starts up, which 
the consumer can connect to. ATM with your code no queue exists until a 
consumer creates it, so all messages before that point are dropped.

<code snipped>

> In addition i have another question , is it possible to make that not
> all the consumers get all the messages  with a fanout exchange, i mean
> is it possible to balance the messages in between the consumers. Thanks
> a lot. regards!

If each consumer creates its own queue, each consumer will get all the 
messages.

If each consumer connects to the same queue, the messages will be 
balanced among the consumers.

NB this balancing will not be very fair if the consumers connect to a 
preexisting queue with a bunch of messages, unless you set the prefetch 
count using basic.qos. Once the existing messages are drained and the 
queue is empty it will round-robin subsequent messages.

Cheers, Simon
>
> Francisco González-Blanch Rodríguez
>
>
> On Fri, Jul 9, 2010 at 1:39 PM, Ovidiu Deac <ovidiudeac at gmail.com
> <mailto:ovidiudeac at gmail.com>> wrote:
>
>     If nobody extracts the message from the queue the message won't be lost.
>
>     On Fri, Jul 9, 2010 at 1:09 PM, Francisco Gonzalez-Blanch
>     <fblanch at gmail.com <mailto:fblanch at gmail.com>> wrote:
>      > Hi all,
>      > I'm a newbie in rabbitmq and i'm working on a distributed data
>     processing
>      > application using rabbitmq as distributed task queue. I want to
>     ask you
>      > about where can i find information about how to make persistent
>     queues, and
>      > how to make that, if a producer sends messages to queue and no
>     one is listen
>      > to it and then a consumer is attached , the consumer gets all the
>     messages,
>      > even the ones that were produced before the consumer was
>     attached. Thank you
>      > very much.
>      >
>      >
>      >
>      > _______________________________________________
>      > rabbitmq-discuss mailing list
>      > rabbitmq-discuss at lists.rabbitmq.com
>     <mailto:rabbitmq-discuss at lists.rabbitmq.com>
>      > https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>      >
>      >
>
>
>
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss

-- 
Simon MacMullen
Staff Engineer, RabbitMQ
SpringSource, a division of VMware