eMAGTechLabs / RabbitMqBundle

RabbitMq/AMQPConnectionFactory.php

Spacing +8 added lines, -8 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;
         }
@@ -74,10 +74,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
                     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'],
@@ -91,10 +91,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'],
@@ -128,7 +128,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']);

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 ($processFlag) {
+        return function($msg) use ($processFlag) {
             return $processFlag;
         };
     }

Command/RpcServerCommand.php

Indentation +2 added lines, -2 removed lines

@@ -42,8 +42,8 @@
         }
 
         $this->getContainer()
-               ->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
-               ->start($amount);
+                ->get(sprintf('old_sound_rabbit_mq.%s_server', $input->getArgument('name')))
+                ->start($amount);
 
         return 0;
     }