contamobi / CmobiRabbitmqBundle

Queue/Queue.php

Spacing +4 added lines, -4 removed lines

@@ -36,7 +36,7 @@ 
         }
         $this->channel = $this->getConnection()->channel();
 
-        if (! $this->channel instanceof CmobiAMQPChannel) {
+        if (!$this->channel instanceof CmobiAMQPChannel) {
             throw new InvalidAMQPChannelException('Failed get AMQPChannel');
         }
 
@@ -51,7 +51,7 @@ 
 
         if ($queueBag->getExchangeDeclare()) {
             $this->getChannel()->exchangeDeclare($queueBag->getExchangeDeclare());
-            list ($queueName, , ) = $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
+            list ($queueName,,) = $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
             $this->getChannel()->queue_bind($queueName, $queueBag->getExchange());
         } else {
             $this->getChannel()->queueDeclare($queueBag->getQueueDeclare());
@@ -66,7 +66,7 @@ 
     {
         $this->createQueue();
 
-        while(count($this->getChannel()->callbacks)) {
+        while (count($this->getChannel()->callbacks)) {
             try {
                 $this->getChannel()->wait();
             } catch (\Exception $e) {
@@ -140,7 +140,7 @@ 
             } catch (\Exception $e) {
                 $failed = true;
                 sleep(3);
-                $this->logger->error('forceReconnect() - ' . $e->getMessage());
+                $this->logger->error('forceReconnect() - '.$e->getMessage());
             }
         } while ($failed);
         $this->logger->warning('forceReconnect() - connected!');