contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcClient.php

Spacing +3 added lines, -3 removed lines

@@ -64,7 +64,7 @@ 
     {
         $this->refreshChannel();
 
-        if (! $this->queueHasExists()) {
+        if (!$this->queueHasExists()) {
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
         }
         $this->correlationId = $this->generateCorrelationId();
@@ -83,7 +83,7 @@ 
             [$this, 'onResponse']
         );
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'correlation_id' => $this->correlationId,
                 'reply_to' => $this->callbackQueue,
@@ -92,7 +92,7 @@ 
         );
         $this->getChannel()->basic_publish($msg, '', $this->getQueueName());
 
-        while (! $this->response) {
+        while (!$this->response) {
             $this->getChannel()->wait(null, 0, ($expire / 1000));
         }
         $this->getChannel()->close();

Transport/Rpc/RpcServerBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -33,7 +33,7 @@
      */
     public function buildQueue($queueName, QueueServiceInterface $queueService, QueueBagInterface $queueBag)
     {
-        if (! $queueBag instanceof RpcQueueBag) {
+        if (!$queueBag instanceof RpcQueueBag) {
             throw new \Exception('Unsupported QueueBag');
         }
         $queue = new Queue($this->getConnectionManager(), $queueBag, $this->logger, $this->connectionName);