contamobi / CmobiRabbitmqBundle

Tests/Queue/QueueTest.php

Spacing +2 added lines, -2 removed lines

@@ -45,7 +45,7 @@ 
      */
     protected function getCmobiAMQPChannelMock()
     {
-        $channelMock =  $this->getMockBuilder(CmobiAMQPChannel::class)
+        $channelMock = $this->getMockBuilder(CmobiAMQPChannel::class)
             ->disableOriginalConstructor()
             ->getMock();
         $channelMock->expects($this->any())
@@ -76,7 +76,7 @@ 
             ->disableOriginalConstructor()
             ->getMock();
         $callbackMock->method('toClosure')
-            ->willReturn(function () {});
+            ->willReturn(function() {});
 
         return $callbackMock;
     }

Connection/ConnectionManager.php

Spacing +2 added lines, -2 removed lines

@@ -20,13 +20,13 @@
     {
         $factory = $this->getContainer()->get($this->factories['default']);
 
-        if (! is_null($name) && array_key_exists($name, $this->factories)) {
+        if (!is_null($name) && array_key_exists($name, $this->factories)) {
             $factory = $this->getContainer()->get(
                 $this->factories[$name]
             );
         }
 
-        if (! $factory instanceof ConnectionFactory) {
+        if (!$factory instanceof ConnectionFactory) {
             throw new NotFoundAMQPConnectionFactoryException(sprintf('%s: connection not found.', $name));
         }
 

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