<div>As far as I can see: my server.php and client.php scripts create <b>different channels</b> (and different connections) which seems to contradict the nature of exclusive queues. <br></div><div>And I cannot see any way to reuse same channel (that is created at client.php) at server.php.<br></div><div><br></div><div>This probably means that I cannot use "official" PECL extension from php.net for building RPC at RabbitMQ: http://www.php.net/manual/en/amqp.installation.php</div><div>I think this issue may be considered as solved: impossible to use this library for RPC :-/</div><div><br></div><div>Thank you</div><div><br></div><div><br>On Thursday, June 21, 2012 1:54:37 PM UTC+4, Alvaro Videla wrote:<blockquote class="gmail_quote" style="margin: 0;margin-left: 0.8ex;border-left: 1px #ccc solid;padding-left: 1ex;">In your Server code you need to publish your messages to the anonymous exchange (which I'm not sure is possible with the library you are using).<div><br></div><div>In your publish call use the queue name that you got in the reply_to property.<br>
<br><div class="gmail_quote">On Thu, Jun 21, 2012 at 11:48 AM, Denis wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Sorry for me writing here: I can't figure out how to use mailing list for replies =/<div><br></div><div><br></div><div>My Client.php declares callback queue php-object as following:</div><div><pre style="line-height:18px;max-height:600px;text-align:left;width:auto;overflow:auto;font-size:14px;background-color:rgb(238,238,238);margin-bottom:10px;font-family:Consolas,Menlo,Monaco,'Lucida Console','Liberation Mono','DejaVu Sans Mono','Bitstream Vera Sans Mono','Courier New',monospace,serif;padding:5px"><code style="font-family:Consolas,Menlo,Monaco,'Lucida Console','Liberation Mono','DejaVu Sans Mono','Bitstream Vera Sans Mono','Courier New',monospace,serif"><span style="background-color:transparent">$callbackQueue </span><span style="background-color:transparent">=</span><span style="background-color:transparent"> </span><span style="background-color:transparent;color:rgb(0,0,139)">new</span><span style="background-color:transparent"> </span><span style="background-color:transparent">\</span><span style="background-color:transparent;color:rgb(43,145,175)">AMQPQueue</span><span style="background-color:transparent">(</span><span style="background-color:transparent">$channel</span><span style="background-color:transparent">);</span><span style="background-color:transparent"><br>
$callbackQueue</span><span style="background-color:transparent">-></span><span style="background-color:transparent">setFlags</span><span style="background-color:transparent">(</span><span style="background-color:transparent">AMQP_<wbr>EXCLUSIVE</span><span style="background-color:transparent">);</span><span style="background-color:transparent"> </span><span style="background-color:transparent;color:gray">// set EXCLUSIVE flag</span><span style="background-color:transparent"><br>
$callbackQueue</span><span style="background-color:transparent">-></span><span style="background-color:transparent">declare</span><span style="background-color:transparent">();</span></code></pre><div>After that I pass it's name at an envelope to server like this ($callbackQueue->getName at 'reply_to')</div>
<div><pre style="line-height:18px;max-height:600px;text-align:left;width:auto;overflow:auto;font-size:14px;background-color:rgb(238,238,238);margin-bottom:10px;font-family:Consolas,Menlo,Monaco,'Lucida Console','Liberation Mono','DejaVu Sans Mono','Bitstream Vera Sans Mono','Courier New',monospace,serif;padding:5px"><code style="font-family:Consolas,Menlo,Monaco,'Lucida Console','Liberation Mono','DejaVu Sans Mono','Bitstream Vera Sans Mono','Courier New',monospace,serif"><span style="background-color:transparent">$exchange</span><span style="background-color:transparent">-></span><span style="background-color:transparent">publish</span><span style="background-color:transparent">(</span><span style="background-color:transparent"><br>
json_encode</span><span style="background-color:transparent">(</span><span style="background-color:transparent">array</span><span style="background-color:transparent">(</span><span style="background-color:transparent;color:rgb(128,0,0)">'process me!'</span><span style="background-color:transparent">)),</span><span style="background-color:transparent"><br>
</span><span style="background-color:transparent;color:rgb(128,0,0)">'temp_action'</span><span style="background-color:transparent">,</span><span style="background-color:transparent"><br> AMQP_MANDATORY</span><span style="background-color:transparent">,</span><span style="background-color:transparent"><br>
array</span><span style="background-color:transparent">(</span><span style="background-color:transparent"><br> </span><span style="background-color:transparent;color:rgb(128,0,0)">'reply_to'</span><span style="background-color:transparent"> </span><span style="background-color:transparent">=></span><span style="background-color:transparent"> $callbackQueue</span><span style="background-color:transparent">-></span><span style="background-color:transparent">getName</span><span style="background-color:transparent">(),</span><span style="background-color:transparent"> </span><span style="background-color:transparent;color:gray">// pass callback queue name</span><span style="background-color:transparent"><br>
</span><span style="background-color:transparent;color:rgb(128,0,0)">'correlation_id'</span><span style="background-color:transparent"> </span><span style="background-color:transparent">=></span><span style="background-color:transparent"> $correlationId<br>
</span><span style="background-color:transparent">)</span><span style="background-color:transparent"><br></span><span style="background-color:transparent">);</span></code></pre></div><div><br></div><div>And my Server.php creates a new Queue php-object (in an anonymous function that handles consuming) as following:<br>
</div><div><pre style="line-height:18px;max-height:600px;text-align:left;width:auto;overflow:auto;font-size:14px;background-color:rgb(238,238,238);margin-bottom:10px;font-family:Consolas,Menlo,Monaco,'Lucida Console','Liberation Mono','DejaVu Sans Mono','Bitstream Vera Sans Mono','Courier New',monospace,serif;padding:5px"><code style="font-family:Consolas,Menlo,Monaco,'Lucida Console','Liberation Mono','DejaVu Sans Mono','Bitstream Vera Sans Mono','Courier New',monospace,serif"><span style="background-color:transparent"> $callbackQueue </span><span style="background-color:transparent">=</span><span style="background-color:transparent"> </span><span style="background-color:transparent;color:rgb(0,0,139)">new</span><span style="background-color:transparent"> </span><span style="background-color:transparent">\</span><span style="background-color:transparent;color:rgb(43,145,175)">AMQPQueue</span><span style="background-color:transparent">(</span><span style="background-color:transparent">$channel</span><span style="background-color:transparent">);</span><span style="background-color:transparent"><br>
$callbackQueue</span><span style="background-color:transparent">-></span><span style="background-color:transparent">setName</span><span style="background-color:transparent">(</span><span style="background-color:transparent">$<wbr>envelope</span><span style="background-color:transparent">-></span><span style="background-color:transparent">getReplyTo</span><span style="background-color:transparent">());</span><span style="background-color:transparent"><br>
$callbackQueue</span><span style="background-color:transparent">-></span><span style="background-color:transparent">setFlags</span><span style="background-color:transparent">(</span><span style="background-color:transparent">AMQP_<wbr>EXCLUSIVE</span><span style="background-color:transparent">);</span><span style="background-color:transparent"> </span><span style="background-color:transparent;color:gray">// set EXCLUSIVE flag</span></code></pre>
</div><div>Right after that moment I'm trying to bind newly created $callbackQueue object to an exchange - and this causes blocking issue.</div><div><br></div><div><br></div><div>I'm not sure which exact options are different (exclusive looks for me to be the only flag I set in both cases). </div>
<div>Setting name in Server.php is necessary and name is taken from envelope's 'reply_to' setting. </div><div><br></div><div>As far as I can see no extra declaration of callback queue is happening on a Server.php side. (Although tempQueue Server consumes messages from is extra declared, but this is made for server to be able to listen that queue even when before any client exists)</div>
<div><br>On Thursday, June 21, 2012 12:33:42 PM UTC+4, Alvaro Videla wrote:</div><blockquote class="gmail_quote" style="margin:0;margin-left:0.8ex;border-left:1px #ccc solid;padding-left:1ex"><div>While not using the same library here you have the official tutorials ported to PHP<div>
<br></div><div><a href="https://github.com/rabbitmq/rabbitmq-tutorials/tree/master/php" target="_blank">https://github.com/rabbitmq/<u></u>ra<wbr>bbitmq-tutorials/tree/<u></u>master/<wbr>php</a></div>
<div><br></div><div>The problem in your code is that you declare queues with different options. </div><div><br></div><div>So as one reply say, if you declare queue A as durable, then every other declaration of that queue must be durable. The same for the exclusive flag.</div>
<div><br></div><div>Also you don't need to redeclare a queue to publish messages to it. As an RPC server you assume that the address sent in the 'reply_to' property is already present. I think is the responsibility of the RpcClient to make sure the queue where it is waiting for replies exists already.</div>
<div><br></div><div>Regards,</div><div><br></div><div>Alvaro</div><div><br></div></div><div><div>And you can indeed do RPC over RabbitMQ by using different connections.<br><br></div><div class="gmail_quote">On Wed, Jun 20, 2012 at 8:03 PM, Denis wrote:<div>
<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex"><span>Hello guys.</span><div><br></div><div>I'm trying to build RPC using PHP, here is my description of problem:</div>
<div><a href="http://stackoverflow.com/questions/11104004/rabbitmq-rpc-exclusive-queues-locking-php" style="color:rgb(17,85,204)" target="_blank">http://stackoverflow.com/<u></u>quest<u></u><wbr>ions/11104004/rabbitmq-<u></u>rpc-<u></u>exc<wbr>lusive-queues-locking-<u></u>php</a></div>
<div><br></div><div>The main issue I suspect is that Client.php and Server.php try to connect to RabbitMQ server using different connections, which leads to inability of using EXCLUSIVE queue (that is declared in CLient.php) from Server.php</div>
<div><br></div><div>Can u give me a way I can dig to? I'm out of ideas ...</div><br>______________________________<u></u><wbr>_________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com" target="_blank">rabbitmq-discuss@lists.<u></u>rabbitm<wbr>q.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/<u></u>cgi<wbr>-bin/mailman/listinfo/<u></u>rabbitmq<wbr>-discuss</a><br>
<br></blockquote></div></div><br></div>
</blockquote></div><br>______________________________<wbr>_________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com" target="_blank">rabbitmq-discuss@lists.<wbr>rabbitmq.com</a><br>
<a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/<wbr>cgi-bin/mailman/listinfo/<wbr>rabbitmq-discuss</a><br>
<br></blockquote></div><br></div>
</blockquote></div>