eMAGTechLabs / RabbitMqBundle

Tests/RabbitMq/MultipleConsumerTest.php

Spacing +3 added lines, -3 removed lines

@@ -246,14 +246,14 @@ 
     {
         $this->amqpChannel->expects($this->any())
             ->method('basic_reject')
-            ->will($this->returnCallback(function ($delivery_tag, $requeue) use ($expectedMethod, $expectedRequeue) {
+            ->will($this->returnCallback(function($delivery_tag, $requeue) use ($expectedMethod, $expectedRequeue) {
                 Assert::assertSame($expectedMethod, 'basic_reject'); // Check if this function should be called.
                 Assert::assertSame($requeue, $expectedRequeue); // Check if the message should be requeued.
             }));
 
         $this->amqpChannel->expects($this->any())
             ->method('basic_ack')
-            ->will($this->returnCallback(function ($delivery_tag) use ($expectedMethod) {
+            ->will($this->returnCallback(function($delivery_tag) use ($expectedMethod) {
                 Assert::assertSame($expectedMethod, 'basic_ack'); // Check if this function should be called.
             }));
     }
@@ -266,7 +266,7 @@ 
      */
     private function prepareCallback($processFlag)
     {
-        return function ($msg) use (&$lastQueue, $processFlag) {
+        return function($msg) use (&$lastQueue, $processFlag) {
             return $processFlag;
         };
     }

RabbitMq/AMQPConnectionFactory.php

Spacing +9 added lines, -9 removed lines

@@ -45,7 +45,7 @@ 
         $this->parameters = array_merge($this->parameters, $parameters);
         $this->parameters = $this->parseUrl($this->parameters);
         if (is_array($this->parameters['ssl_context'])) {
-            $this->parameters['ssl_context'] = ! empty($this->parameters['ssl_context'])
+            $this->parameters['ssl_context'] = !empty($this->parameters['ssl_context'])
                 ? stream_context_create(array('ssl' => $this->parameters['ssl_context']))
                 : null;
         }
@@ -67,17 +67,17 @@ 
             return $ref->newInstanceArgs($this->parameters['constructor_args']);
         }
 
-        if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class , 'PhpAmqpLib\Connection\AMQPSocketConnection')) {
+        if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class, 'PhpAmqpLib\Connection\AMQPSocketConnection')) {
             return new AMQPSocketConnection(
                 $this->parameters['host'],
                 $this->parameters['port'],
                 $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
                 isset($this->parameters['read_timeout']) ? $this->parameters['read_timeout'] : $this->parameters['read_write_timeout'],
                 $this->parameters['keepalive'],
                 isset($this->parameters['write_timeout']) ? $this->parameters['write_timeout'] : $this->parameters['read_write_timeout'],
@@ -90,10 +90,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'],
@@ -127,7 +127,7 @@ 
             $parameters['host'] = urldecode($url['host']);
         }
         if (isset($url['port'])) {
-            $parameters['port'] = (int)$url['port'];
+            $parameters['port'] = (int) $url['port'];
         }
         if (isset($url['user'])) {
             $parameters['user'] = urldecode($url['user']);