contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcServerBuilder.php

Spacing +1 added lines, -1 removed lines

@@ -30,7 +30,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->connectionName);

Transport/Worker/WorkerBuilder.php

Spacing +1 added lines, -1 removed lines

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

Queue/Queue.php

Spacing +3 added lines, -3 removed lines

@@ -143,17 +143,17 @@
         do {
             try {
                 $failed = false;
-                fwrite($this->logOutput, 'start forceReconnect() - trying connect...' . PHP_EOL);
+                fwrite($this->logOutput, 'start forceReconnect() - trying connect...'.PHP_EOL);
                 $this->connection = $this->getConnectionManager()->getConnection($this->connectionName);
                 $this->channel = $this->getConnection()->channel();
                 $this->createQueue();
             } catch (\Exception $e) {
                 $failed = true;
                 sleep(3);
-                fwrite($this->logOutput, 'failed forceReconnect() - ' . $e->getMessage() . PHP_EOL);
+                fwrite($this->logOutput, 'failed forceReconnect() - '.$e->getMessage().PHP_EOL);
             }
         } while ($failed);
-        fwrite($this->logOutput, 'forceReconnect() - connected!' . PHP_EOL);
+        fwrite($this->logOutput, 'forceReconnect() - connected!'.PHP_EOL);
 
         return $this->channel;
     }