contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcClient.php

Spacing +8 added lines, -8 removed lines

@@ -47,7 +47,7 @@ 
     public function createCallbackQueue(CmobiAMQPChannel $channel, $expire, $corralationId = null, $sufix = null)
     {
         $this->correlationId = is_null($corralationId) ? $this->generateCorrelationId() : $corralationId;
-        $sufix = is_null($sufix) ? Uuid::uuid4()->toString() . microtime() : $sufix;
+        $sufix = is_null($sufix) ? Uuid::uuid4()->toString().microtime() : $sufix;
         $queueBag = new RpcQueueBag(
             sprintf(
                 'callback_to_%s_from_%s_%s',
@@ -84,12 +84,12 @@ 
         $connection = $this->connectionManager->getConnection($this->connectionName);
         $channel = $connection->channel();
 
-        if (! $this->queueHasExists($channel)) {
+        if (!$this->queueHasExists($channel)) {
             throw new QueueNotFoundException("Queue $this->queueName not declared.");
         }
         $this->createCallbackQueue($channel, $expire);
         $msg = new CmobiAMQPMessage(
-            (string) $data,
+            (string)$data,
             [
                 'correlation_id' => $this->correlationId,
                 'reply_to' => $this->callbackQueue,
@@ -98,7 +98,7 @@ 
         );
         $channel->basic_publish($msg, '', $this->getQueueName());
 
-        while (! $this->response) {
+        while (!$this->response) {
             try {
                 $channel->wait(null, 0, ($expire / 1000));
             } catch (\Exception $e) {
@@ -168,7 +168,7 @@ 
     /** @return string */
     public function generateCorrelationId()
     {
-        return uniqid($this->getQueueName()) . Uuid::uuid4()->toString() . microtime();
+        return uniqid($this->getQueueName()).Uuid::uuid4()->toString().microtime();
     }
 
     /**
@@ -217,7 +217,7 @@ 
                 $connection->close();
                 sleep(2);
                 $failed = false;
-                fwrite($this->logOutput, 'start RpcClient::forceReconnect() - trying connect...' . PHP_EOL);
+                fwrite($this->logOutput, 'start RpcClient::forceReconnect() - trying connect...'.PHP_EOL);
                 $connection = $this->getConnectionManager()->getConnection($this->connectionName);
                 $channel = $connection->channel();
                 $this->createCallbackQueue($channel, $expire, $corralationId);
@@ -225,10 +225,10 @@ 
                 $tries++;
                 $failed = true;
                 sleep(3);
-                fwrite($this->errOutput, 'failed RpcClient::forceReconnect() - ' . $e->getMessage() . PHP_EOL);
+                fwrite($this->errOutput, 'failed RpcClient::forceReconnect() - '.$e->getMessage().PHP_EOL);
             }
         } while ($failed || $tries > 2);
-        fwrite($this->logOutput, 'RpcClient::forceReconnect() - connected!' . PHP_EOL);
+        fwrite($this->logOutput, 'RpcClient::forceReconnect() - connected!'.PHP_EOL);
 
         return $connection;
     }