<span style="font-family: Arial;">Thanks alvaro like I said this concept is totally new to me , however I would like to know if the consumers would run stand alone , that is apart from the web server ? , if that is the case does it mean I would have to keep my command line open always on my servers?<br><br><br>----- Reply message -----<br>From: rabbitmq-discuss-request@lists.rabbitmq.com<br>To: &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Subject: rabbitmq-discuss Digest, Vol 76, Issue 24<br>Date: Mon, Sep 23, 2013 12:00 PM<br><br></span><br>Send rabbitmq-discuss mailing list submissions to<br>        rabbitmq-discuss@lists.rabbitmq.com<br><br>To subscribe or unsubscribe via the World Wide Web, visit<br>        https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss<br>or, via email, send a message with subject or body &#39;help&#39; to<br>        rabbitmq-discuss-request@lists.rabbitmq.com<br><br>You can reach the person managing the list at<br>        rabbitmq-discuss-owner@lists.rabbitmq.com<br><br>When replying, please edit your Subject line so it is more specific<br>than &quot;Re: Contents of rabbitmq-discuss digest...&quot;<br><br><br>Today&#39;s Topics:<br><br> &nbsp; 1. Troubleshooting RabbitMQ (Sukhjeet Singh)<br> &nbsp; 2. federate the unnamed queue? (Greg Roy)<br> &nbsp; 3. Re: Troubleshooting RabbitMQ (Michael Klishin)<br> &nbsp; 4. Re: federate the unnamed queue? (Michael Klishin)<br> &nbsp; 5. Re: federate the unnamed queue? (Alvaro Videla)<br> &nbsp; 6. Re: Producer consumer in background on a web        server<br> &nbsp; &nbsp; &nbsp;(Alvaro Videla)<br> &nbsp; 7. Re: Federation setup query (Jain, Punit)<br> &nbsp; 8. Re: Questiong about plugins and clustering (Simon MacMullen)<br> &nbsp; 9. Re: federate the unnamed queue? (Simon MacMullen)<br> &nbsp;10. Re: Troubleshooting RabbitMQ (Simon MacMullen)<br> &nbsp;11. Re: Questiong about plugins and clustering (Emile Joubert)<br> &nbsp;12. Re: How do the Producer gets response from the subscribers<br> &nbsp; &nbsp; &nbsp;(Matthias Radestock)<br><br><br>----------------------------------------------------------------------<br><br>Message: 1<br>Date: Sun, 22 Sep 2013 07:39:55 -0400<br>From: Sukhjeet Singh &lt;princu.chana@gmail.com&gt;<br>Subject: [rabbitmq-discuss] Troubleshooting RabbitMQ<br>To: rabbitmq-discuss@lists.rabbitmq.com<br>Message-ID:<br>        &lt;CAB9W+YKEJ6qNX89Cj2SfEO7d85cweod-XYKS=uMGr_VhDmAYBQ@mail.gmail.com&gt;<br>Content-Type: text/plain; charset=&quot;iso-8859-1&quot;<br><br>Sir/Madam,<br> &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; This is for first time I am using RabbitMQ. After<br>searching, I come to know that first I have to install RabbitMq sever and<br>after doing that I used a code sample given in rabbitMq&#39;s official site.I<br>am pasting that code here also. I also tried to search the resolution of<br>this error but I am not able to get it&#39;s solution. This is a request to<br>please help me as soon as it can br possible.<br><br>Actually, the problem is that createConnection() method is throwing an<br>exception and the exception is &quot;BrokerUnreachableException was Unhandled&quot;.<br><br>Please HELP ASAP.<br><br>Thanks.<br>-------------- next part --------------<br>An HTML attachment was scrubbed...<br>URL: &lt;http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/734cd42a/attachment.html&gt;<br><br>------------------------------<br><br>Message: 2<br>Date: Sun, 22 Sep 2013 10:47:13 -0400<br>From: Greg Roy &lt;gj.roy75@gmail.com&gt;<br>Subject: [rabbitmq-discuss] federate the unnamed queue?<br>To: rabbitmq-discuss@lists.rabbitmq.com<br>Message-ID:<br>        &lt;CAKAqKjuD_5=59Yb4m55UUk+PdeWHu0VRLb8H0-TczarUnA2FWA@mail.gmail.com&gt;<br>Content-Type: text/plain; charset=&quot;iso-8859-1&quot;<br><br>Hello All,<br><br>I would like to federate all messages to the default unnamed queue - is<br>this possible? &nbsp;I have tried variations of pattern matching nothing, but<br>believe I&#39;ll need to alter my publishing behaviour. &nbsp;True or false?<br><br>Thanks in advance,<br><br>Greg<br>-------------- next part --------------<br>An HTML attachment was scrubbed...<br>URL: &lt;http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/960fa966/attachment-0001.htm&gt;<br><br>------------------------------<br><br>Message: 3<br>Date: Sun, 22 Sep 2013 19:31:17 +0100<br>From: Michael Klishin &lt;michael@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] Troubleshooting RabbitMQ<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID: &lt;BCD3D9F4-D067-4352-B546-9D2F20CDA81E@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=&quot;iso-8859-1&quot;<br><br><br>On sep 22, 2013, at 12:39 p.m., Sukhjeet Singh &lt;princu.chana@gmail.com&gt; wrote:<br><br>&gt; Actually, the problem is that createConnection() method is throwing an exception and the exception is &quot;BrokerUnreachableException was Unhandled&quot;. <br><br>Sukhjeet,<br><br>Can you please be a bit more specific about<br><br> * What the stack trace look like<br> * How did you install RabbitMQ<br> * If it is running<br> * If there&#39;s anything in the log<br> * What tutorial are you following and for what language<br><br>Then it will be much easier to provide specific advice.<br><br>MK<br><br><br><br>-------------- next part --------------<br>A non-text attachment was scrubbed...<br>Name: signature.asc<br>Type: application/pgp-signature<br>Size: 495 bytes<br>Desc: Message signed with OpenPGP using GPGMail<br>URL: &lt;http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/7b2dd9a8/attachment-0001.pgp&gt;<br><br>------------------------------<br><br>Message: 4<br>Date: Sun, 22 Sep 2013 19:33:20 +0100<br>From: Michael Klishin &lt;michael@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] federate the unnamed queue?<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID: &lt;3E151093-B43C-4B67-91B8-B5DC40A66711@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=&quot;iso-8859-1&quot;<br><br>Greg,<br><br>On sep 22, 2013, at 3:47 p.m., Greg Roy &lt;gj.roy75@gmail.com&gt; wrote:<br><br>&gt; I would like to federate all messages to the default unnamed queue - is this possible?<br><br>It&#39;s the default exchange that is &quot;unnamed&quot; (clients specify an empty string to refer to it).<br>Queue federation will be supposed in the next release (3.2). Are you talking about<br>exchanges?<br><br>&gt; &nbsp;I have tried variations of pattern matching nothing, but believe I&#39;ll need to alter my publishing behaviour.<br><br>It should be possible to federate any exchange, as far as I know. Can you post some specific<br>federation configuration examples and you code, and explain what your queues and bindings<br>setup is?<br><br>MK<br><br><br><br>-------------- next part --------------<br>A non-text attachment was scrubbed...<br>Name: signature.asc<br>Type: application/pgp-signature<br>Size: 495 bytes<br>Desc: Message signed with OpenPGP using GPGMail<br>URL: &lt;http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/c4af5071/attachment-0001.pgp&gt;<br><br>------------------------------<br><br>Message: 5<br>Date: Sun, 22 Sep 2013 14:47:50 -0500<br>From: Alvaro Videla &lt;videlalvaro@gmail.com&gt;<br>Subject: Re: [rabbitmq-discuss] federate the unnamed queue?<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID:<br>        &lt;CAMcAHLXy=RSE9=L=8rr9HS4sGJtZj4eGwDqSOwFpTXLtVq_87A@mail.gmail.com&gt;<br>Content-Type: text/plain; charset=&quot;iso-8859-1&quot;<br><br>Hi,<br><br>If by &quot;unnamed queue&quot; you mean the default exchange with no name, then no,<br>you can&#39;t federate that exchange.<br><br>Regards,<br><br>Alvaro<br><br><br>On Sun, Sep 22, 2013 at 9:47 AM, Greg Roy &lt;gj.roy75@gmail.com&gt; wrote:<br><br>&gt; Hello All,<br>&gt;<br>&gt; I would like to federate all messages to the default unnamed queue - is<br>&gt; this possible? &nbsp;I have tried variations of pattern matching nothing, but<br>&gt; believe I&#39;ll need to alter my publishing behaviour. &nbsp;True or false?<br>&gt;<br>&gt; Thanks in advance,<br>&gt;<br>&gt; Greg<br>&gt;<br>&gt; _______________________________________________<br>&gt; rabbitmq-discuss mailing list<br>&gt; rabbitmq-discuss@lists.rabbitmq.com<br>&gt; https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss<br>&gt;<br>&gt;<br>-------------- next part --------------<br>An HTML attachment was scrubbed...<br>URL: &lt;http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/9f82ec8f/attachment-0001.htm&gt;<br><br>------------------------------<br><br>Message: 6<br>Date: Sun, 22 Sep 2013 14:59:19 -0500<br>From: Alvaro Videla &lt;videlalvaro@gmail.com&gt;<br>Subject: Re: [rabbitmq-discuss] Producer consumer in background on a<br>        web        server<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID:<br>        &lt;CAMcAHLVv+65CpZ_eZwLn1b=fd_+dfawHXOB_gWERnkfURu6TXg@mail.gmail.com&gt;<br>Content-Type: text/plain; charset=&quot;iso-8859-1&quot;<br><br>Hi<br><br>On Sun, Sep 22, 2013 at 6:34 AM, tyger2007@yahoo.com &lt;tyger2007@yahoo.com&gt;wrote:<br><br>&gt; how do I make my php consumers work without running them on a command-line<br>&gt; to listen to producer messages ?<br><br><br>What do you mean by this? You can just run the PHP consumer directly on the<br>webserver process, although I wouldn&#39;t recommend doing that since you would<br>end up blocking all the server threads.<br><br>Is there a reason why you don&#39;t want to run the consumer from the command<br>line directly?<br><br>Regards,<br><br>Alvaro<br>-------------- next part --------------<br>An HTML attachment was scrubbed...<br>URL: &lt;http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130922/1934f66e/attachment-0001.htm&gt;<br><br>------------------------------<br><br>Message: 7<br>Date: Mon, 23 Sep 2013 02:23:27 -0400<br>From: &quot;Jain, Punit&quot; &lt;Punit.Jain@emc.com&gt;<br>Subject: Re: [rabbitmq-discuss] Federation setup query<br>To: Simon MacMullen &lt;simon@rabbitmq.com&gt;<br>Cc: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID:<br>        &lt;DB14E94115BBC84E8960C12C176D06760127ECAD05@MX25A.corp.emc.com&gt;<br>Content-Type: text/plain; charset=&quot;us-ascii&quot;<br><br><br><br>&gt; -----Original Message-----<br>&gt; From: Simon MacMullen [mailto:simon@rabbitmq.com]<br>&gt; Sent: Friday, September 20, 2013 9:22 PM<br>&gt; To: Jain, Punit<br>&gt; Cc: Discussions about RabbitMQ<br>&gt; Subject: Re: [rabbitmq-discuss] Federation setup query<br>&gt; <br>&gt; On 20/09/2013 1:26PM, Jain, Punit wrote:<br>&gt; &gt; Hi, We are using federation setup with two URIs defined in an<br>&gt; &gt; upstream, as suggested by you. I simulated link failure by closing one<br>&gt; &gt; of the Ethernet port. I observed that it takes around 15-20 minutes to<br>&gt; &gt; switch link. Why is it taking this much time? Is there a way I can<br>&gt; &gt; decrease the switch time?<br>&gt; <br>&gt; It should switch as soon as the &quot;old&quot; AMQP connection goes down - so check<br>&gt; your heartbeat settings.<br>&gt; <br><br>I think it was set to default value which is 600. I changed it to 30 seconds on upstream.<br>Now it detects the failure in around a minute and changes the link.<br><br><br>&gt; &gt; One more question: on the same setup, I stopped RabbitMQ server on<br>&gt; &gt; downstream and started it after few seconds. Sometimes the messages<br>&gt; &gt; published to upstream exchange during that duration are lost. Though,<br>&gt; &gt; they were present in the upstream queue during that period, but lost<br>&gt; &gt; after the downstream broker was started.<br>&gt; <br>&gt; Hmm.<br>&gt; <br>&gt; Of course that shouldn&#39;t be happening. How do you know they are lost? In<br>&gt; particular, it&#39;s possible for the downstream bindings to change while a link is<br>&gt; down, in which case messages can be queued on the upstream, then when the<br>&gt; link comes back they get transferred over and then dropped.<br>&gt; Could something like that be happening? The tracer might be helpful to see if<br>&gt; these messages are indeed getting published downstream.<br>&gt;<br><br><br>This behavior was observed when both links were up, but we just stopped and started the downstream broker. <br>Bindings were not changed, there was only one queue listening to downstream stream with &#39;#&#39; routing key.<br>I will use tracer when I observe this next time.<br> <br>Thank you, Simon.<br><br>&gt; Cheers, Simon<br>&gt; <br>&gt; --<br>&gt; Simon MacMullen<br>&gt; RabbitMQ, Pivotal<br><br><br><br>------------------------------<br><br>Message: 8<br>Date: Mon, 23 Sep 2013 09:41:23 +0100<br>From: Simon MacMullen &lt;simon@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] Questiong about plugins and clustering<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID: &lt;523FFEB3.9050109@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=ISO-8859-1; format=flowed<br><br>On 21/09/2013 02:53, Alvaro Videla wrote:<br>&gt; Is there a way for a plugin to know when a node joins or leaves the<br>&gt; cluster?<br><br>No, not at the moment. Currently we just ask Mnesia whenever we need to <br>know.<br><br>&gt; Is there any notification that can be received by my plugin about this<br>&gt; event happening or I need to poll Mnesia once in a while?<br><br>Well, you can invoke rabbit_mnesia:cluster_nodes(running) or <br>rabbit_mnesia:cluster_nodes(all) or whatever.<br><br>&gt; I see there&#39;s rabbit_node_monitor:notify_joined_cluster/0 but that&#39;s<br>&gt; doesn&#39;t seem to help me.<br><br>No, that&#39;s the other way round - used to tell the node monitor that a <br>node has joined.<br><br>What are you trying to do?<br><br>Cheers, Simon<br><br><br><br>------------------------------<br><br>Message: 9<br>Date: Mon, 23 Sep 2013 10:01:39 +0100<br>From: Simon MacMullen &lt;simon@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] federate the unnamed queue?<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Cc: Greg Roy &lt;gj.roy75@gmail.com&gt;<br>Message-ID: &lt;52400373.5080005@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=ISO-8859-1; format=flowed<br><br>On 22/09/2013 19:33, Michael Klishin wrote:<br>&gt; It should be possible to federate any exchange, as far as I know.<br><br>As Alvaro pointed out, it&#39;s any exchange other than the default exchange <br>(since the &quot;default exchange&quot; really just means &quot;publish to queue&quot;).<br><br>I&#39;ll update the documentation to make this clearer.<br><br>Cheers, Simon<br><br><br><br>------------------------------<br><br>Message: 10<br>Date: Mon, 23 Sep 2013 10:04:51 +0100<br>From: Simon MacMullen &lt;simon@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] Troubleshooting RabbitMQ<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Cc: Sukhjeet Singh &lt;princu.chana@gmail.com&gt;<br>Message-ID: &lt;52400433.1060904@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=ISO-8859-1; format=flowed<br><br>On 22/09/2013 12:39, Sukhjeet Singh wrote:<br>&gt; Actually, the problem is that createConnection() method is throwing an<br>&gt; exception and the exception is &quot;BrokerUnreachableException was Unhandled&quot;.<br><br>The clue&#39;s in the name. The broker was not reachable. Catch the <br>exception to find out more, but I would bet that you haven&#39;t pointed the <br>ConnectionFactory at the broker.<br><br>Cheers, Simon<br><br><br>------------------------------<br><br>Message: 11<br>Date: Mon, 23 Sep 2013 10:06:36 +0100<br>From: Emile Joubert &lt;emile@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] Questiong about plugins and clustering<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Message-ID: &lt;5240049C.4060204@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=ISO-8859-1<br><br><br><br>Hi Alvaro,<br><br>On 21/09/13 02:53, Alvaro Videla wrote:<br><br>&gt; Is there a way for a plugin to know when a node joins or leaves the<br>&gt; cluster? <br><br>A plugin could subscribe to Mnesia system events that will report when<br>Mnesia stops and starts on nodes:<br> http://www.erlang.org/doc/apps/mnesia/Mnesia_chap5.html#id76679<br><br>Depending on the kind of plugin you are writing you could use the<br>information sent to the log exchange (amq.rabbitmq.log) to determine<br>when nodes leave and join.<br><br><br><br>-Emile<br><br><br><br><br><br>------------------------------<br><br>Message: 12<br>Date: Mon, 23 Sep 2013 10:16:53 +0100<br>From: Matthias Radestock &lt;matthias@rabbitmq.com&gt;<br>Subject: Re: [rabbitmq-discuss] How do the Producer gets response from<br>        the subscribers<br>To: Discussions about RabbitMQ &lt;rabbitmq-discuss@lists.rabbitmq.com&gt;<br>Cc: ramkkk &lt;mramu789@gmail.com&gt;<br>Message-ID: &lt;52400705.3000600@rabbitmq.com&gt;<br>Content-Type: text/plain; charset=ISO-8859-1; format=flowed<br><br>On 19/09/13 13:15, ramkkk wrote:<br>&gt; Producer the sends a command to the consumer &nbsp;to spawn the process . so each<br>&gt; consumer has to give the response back to the Producer ..<br>&gt;<br>&gt; &nbsp; but i am not getting the response back to the Producer, consumer is going<br>&gt; on the infinite loop...<br>&gt; [...]<br>&gt; consumer code<br>&gt; [...]<br>&gt; &nbsp; &nbsp; &nbsp;def on_request(self,ch, method, props, body):<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.spawn_processes(2)<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.response = [process.pid for process in self.spawned_processes]<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;ch.basic_publish(exchange=&#39;logs&#39;,<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; routing_key=&#39;&#39;,<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; properties=pika.BasicProperties(correlation_id = \<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; props.correlation_id,<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; delivery_mode=2 ,<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ),<br>&gt;<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; body=str(self.response))<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;ch.basic_ack(delivery_tag = method.delivery_tag)<br><br>The consumer is publishing the response to the &#39;logs&#39; exchange with a &#39;&#39; <br>routing key, whereas...<br><br>&gt; Producer<br>&gt; [...]<br>&gt; &nbsp; &nbsp; &nbsp;def __init__(self):<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.connection = pika.BlockingConnection(pika.ConnectionParameters(<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;host=&#39;localhost&#39;))<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.channel = self.connection.channel()<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.channel.exchange_declare(exchange=&#39;logs&#39;,<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; type=&#39;fanout&#39;)<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;result = self.channel.queue_declare(exclusive=True)<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.callback_queue = result.method.queue<br>&gt;<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.channel.basic_qos(prefetch_count=1)<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp;self.channel.basic_consume(self.on_response, no_ack=True,<br>&gt; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; queue=self.callback_queue)<br><br>...the producer is expecting replies on an exclusive, server-named queue.<br><br>Clearly that isn&#39;t going to work. And because the &#39;logs&#39; exchange is <br>also the exchange on which the consumer queue is bound you end up with <br>the &#39;infinite loop&#39; at the consumer since the response published by the <br>consumer will be consumed by the consumer!<br><br>You need to change your consumer to publish the response to the default <br>exchange (&#39;&#39;) with the routing_key taken from props.reply_to of the request.<br><br>Matthias.<br><br><br>------------------------------<br><br>_______________________________________________<br>rabbitmq-discuss mailing list<br>rabbitmq-discuss@lists.rabbitmq.com<br>https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss<br><br><br>End of rabbitmq-discuss Digest, Vol 76, Issue 24<br>************************************************<br>