contamobi / CmobiRabbitmqBundle

Connection/ConnectionFactory.php

Spacing +4 added lines, -4 removed lines

@@ -36,7 +36,7 @@ 
      */
     public function __construct($class, array $parameters)
     {
-        if (! is_a($class, AMQPStreamConnection::class, true)) {
+        if (!is_a($class, AMQPStreamConnection::class, true)) {
             throw new InvalidAMQPConnectionClassException('$class not instance of AMQPStreamConnection');
         }
         $this->class = $class;
@@ -78,10 +78,10 @@ 
             $this->parameters['user'],
             $this->parameters['password'],
             $this->parameters['vhost'],
-            false,      // insist
+            false, // insist
             'AMQPLAIN', // login_method
-            null,       // login_response
-            'en_US',    // locale
+            null, // login_response
+            'en_US', // locale
             $this->parameters['connection_timeout'],
             $this->parameters['read_write_timeout'],
             $this->parameters['ssl_context'],

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!');