Adding timeout to RPC call when waiting for replies

Author: Pouyan

README.md

@@ -393,7 +393,13 @@ public function indexAction($name)
 {
     $client = $this->get('old_sound_rabbit_mq.integer_store_rpc');
     $client->addRequest(serialize(array('min' => 0, 'max' => 10)), 'random_int', 'request_id');
-    $replies = $client->getReplies();
+    $timout = 5; // seconds
+    try {
+        $replies = $client->getReplies($timeout);
+        // process $replies['request_id'];
+    } catch (\PhpAmqpLib\Exception\AMQPTimeoutException $e) {
+        // handle timeout
+    }
 }
 ```
 

RabbitMq/RpcClient.php

@@ -31,13 +31,13 @@ public function addRequest($msgBody, $server, $requestId = null, $routingKey = '
         $this->requests++;
     }
 
-    public function getReplies()
+    public function getReplies($timeout = 0)
     {
         $this->replies = array();
         $this->getChannel()->basic_consume($this->queueName, '', false, true, false, false, array($this, 'processMessage'));
 
         while (count($this->replies) < $this->requests) {
-            $this->getChannel()->wait();
+            $this->getChannel()->wait(null, false, $timeout);
         }
 
         $this->getChannel()->basic_cancel($this->queueName);