<html>
<head>
<meta content="text/html; charset=ISO-8859-1"
http-equiv="Content-Type">
</head>
<body text="#000000" bgcolor="#FFFFFF">
<div class="moz-cite-prefix">Hi again,<br>
<br>
I adjust my application code to not declare the same queue name.
My test is not for worker queue but for pub/sub so all workers
should receive messages on exchange 'workflow'.<br>
Each worker creates a unique queue and binds it to the workflow
exchange using same key _workflow.<br>
Here is some info.<br>
<br>
---------------------------<br>
darren@nebula:~$ sudo rabbitmqctl list_bindings<br>
Listing bindings ...<br>
exchange amq.gen-mlvwhjMS9xP1KAaQtIMHcg queue
amq.gen-mlvwhjMS9xP1KAaQtIMHcg []<br>
exchange celery queue celery []<br>
celery exchange celery queue celery []<br>
workflow exchange amq.gen-mlvwhjMS9xP1KAaQtIMHcg queue
_workflow []<br>
...done.<br>
darren@nebula:~$ sudo rabbitmqctl list_exchanges<br>
Listing exchanges ...<br>
...<br>
workflow topic<br>
...done.<br>
<br>
---------------------------<br>
<br>
In above, a single worker creates exclusive queue and binds to
'workflow' topic exchange using _workflow key.<br>
<br>
Whenever I publish messages to _workflow key on 'workflow'
exchange, no messages are delivered to the bound queue or
callbacks for it.<br>
Oddly, when i run the pub/sub examples using workflow exchange on
_workflow key, they work among themselves only but<br>
their output looks same as above.<br>
<br>
Any help is appreciated.<br>
<br>
Darren<br>
<br>
<br>
On 09/04/2013 09:10 AM, Michael Klishin wrote:<br>
</div>
<blockquote
cite="mid:C816308A-813C-40E1-8A2C-072E26E175B6@rabbitmq.com"
type="cite">
<pre wrap="">Simon MacMullen:
</pre>
<blockquote type="cite">
<pre wrap="">Because both receivers declare a queue with the same name, they both get the same queue. Each message can only exist once in a queue, so therefore you distribute the messages between the two receivers.
</pre>
</blockquote>
<pre wrap="">
For an explanation of how messages are distributed when multiple consumers
share a queue, see tutorial 2:
<a class="moz-txt-link-freetext" href="https://www.rabbitmq.com/tutorials/tutorial-two-python.html">https://www.rabbitmq.com/tutorials/tutorial-two-python.html</a>
Message routing happens between queues, not between consumers.
See <a class="moz-txt-link-freetext" href="https://www.rabbitmq.com/tutorials/amqp-concepts.html">https://www.rabbitmq.com/tutorials/amqp-concepts.html</a> if you are still not
sure about the concepts.
MK
</pre>
<br>
<fieldset class="mimeAttachmentHeader"></fieldset>
<br>
<pre wrap="">_______________________________________________
rabbitmq-discuss mailing list
<a class="moz-txt-link-abbreviated" href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a>
<a class="moz-txt-link-freetext" href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a>
</pre>
</blockquote>
<br>
</body>
</html>