contamobi / CmobiRabbitmqBundle

Rpc/Exception/RpcInvalidRequestException.php

Spacing +1 added lines, -1 removed lines

@@ -7,7 +7,7 @@
 {
     const ERROR_CODE = -32600;
 
-    public function __construct($message = null,\Exception $previous = null)
+    public function __construct($message = null, \Exception $previous = null)
     {
         if (is_null($message)) {
             $message = 'Invalid Request';

Rpc/RpcClient.php

Spacing +4 added lines, -4 removed lines

@@ -42,7 +42,7 @@ 
      */
     public function onResponse(AMQPMessage $rep)
     {
-        if($rep->get('correlation_id') == $this->correlationId) {
+        if ($rep->get('correlation_id') == $this->correlationId) {
             $this->response = $rep->body;
         }
     }
@@ -192,8 +192,8 @@ 
         $expire = self::DEFAULT_TTL
     )
     {
-        list($callbackQueue, ,) = $this->getChannel()->queue_declare(
-            'callback_to_' . $this->getQueueName() . uniqid('', true), false, false, false, true, false, [
+        list($callbackQueue,,) = $this->getChannel()->queue_declare(
+            'callback_to_'.$this->getQueueName().uniqid('', true), false, false, false, true, false, [
                 'x-message-ttl' => ['I', $expire],
                 'x-max-priority' => ['I', RpcRequestCollectionInterface::PRIORITY_MAX]
             ]
@@ -214,7 +214,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while(!$this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait();
         }
         $this->getChannel()->close();