contamobi / CmobiRabbitmqBundle

Rpc/RpcClient.php

Doc Comments +1 added lines, -1 removed lines

@@ -107,7 +107,7 @@
     }
 
     /**
-     * @return ConnectionManagerInterface
+     * @return AMQPStreamConnection
      */
     public function getConnection()
     {

Spacing +3 added lines, -3 removed lines

@@ -30,7 +30,7 @@ 
      */
     public function onResponse(AMQPMessage $rep)
     {
-        if($rep->get('correlation_id') == $this->correlationId) {
+        if ($rep->get('correlation_id') == $this->correlationId) {
             $this->response = $rep->body;
         }
     }
@@ -40,7 +40,7 @@ 
      */
     public function call()
     {
-        list($callbackQueue, ,) = $this->getChannel()->queue_declare(
+        list($callbackQueue,,) = $this->getChannel()->queue_declare(
             '', false, false, true, false
         );
         $this->callbackQueue = $callbackQueue;
@@ -60,7 +60,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while(!$this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait();
         }
         return $this->response;