eMAGTechLabs / RabbitMqBundle

Command/SetupFabricCommand.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
         $partsHolder = $this->getContainer()->get('old_sound_rabbit_mq.parts_holder');
 
         foreach (array('base_amqp', 'binding') as $key) {
-            foreach ($partsHolder->getParts('old_sound_rabbit_mq.' . $key) as $baseAmqp) {
+            foreach ($partsHolder->getParts('old_sound_rabbit_mq.'.$key) as $baseAmqp) {
                 if ($baseAmqp instanceof DynamicConsumer) {
                     continue;
                 }

MemoryChecker/MemoryConsumptionChecker.php

Spacing +1 added lines, -1 removed lines

@@ -59,7 +59,7 @@
             }
         }
 
-        return (int)$numerical;
+        return (int) $numerical;
     }
 
 }

Tests/RabbitMq/RpcClientTest.php

Spacing +2 added lines, -2 removed lines

@@ -26,7 +26,7 @@ 
         $serializer->expects($this->once())->method('deserialize')->with('message', 'json', null);
         $client->initClient(true);
         $client->setUnserializer(function($data) use ($serializer) {
-            $serializer->deserialize($data, 'json','');
+            $serializer->deserialize($data, 'json', '');
         });
         $client->processMessage($message);
     }
@@ -45,7 +45,7 @@ 
             ->setConstructorArgs(array($expectedNotify))
             ->getMock();
         $notified = false;
-        $client->notify(function ($message) use (&$notified) {
+        $client->notify(function($message) use (&$notified) {
             $notified = $message;
         });
 

Tests/RabbitMq/AMQPConnectionFactoryTest.php

Spacing +117 added lines, -117 removed lines

@@ -22,19 +22,19 @@ 
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
         $this->assertEquals(array(
             'localhost', // host
-            5672,        // port
-            'guest',     // user
-            'guest',     // password
-            '/',         // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            3,           // connection timeout
-            3,           // read write timeout
-            null,        // context
-            false,       // keepalive
-            0,           // heartbeat
+            5672, // port
+            'guest', // user
+            'guest', // password
+            '/', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            3, // connection timeout
+            3, // read write timeout
+            null, // context
+            false, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -50,18 +50,18 @@ 
         $this->assertInstanceOf('PhpAmqpLib\Connection\AMQPSocketConnection', $instance);
         $this->assertEquals(array(
             'localhost', // host
-            5672,        // port
-            'guest',     // user
-            'guest',     // password
-            '/',         // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            3,           // read_timeout
-            false,       // keepalive
-            3,           // write_timeout
-            0,           // heartbeat
+            5672, // port
+            'guest', // user
+            'guest', // password
+            '/', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            3, // read_timeout
+            false, // keepalive
+            3, // write_timeout
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -80,18 +80,18 @@ 
         $this->assertInstanceOf('PhpAmqpLib\Connection\AMQPSocketConnection', $instance);
         $this->assertEquals(array(
             'localhost', // host
-            5672,        // port
-            'guest',     // user
-            'guest',     // password
-            '/',         // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            31,           // read_timeout
-            false,       // keepalive
-            32,           // write_timeout
-            0,           // heartbeat
+            5672, // port
+            'guest', // user
+            'guest', // password
+            '/', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            31, // read_timeout
+            false, // keepalive
+            32, // write_timeout
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -112,20 +112,20 @@ 
         $instance = $factory->createConnection();
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
         $this->assertEquals(array(
-            'foo_host',  // host
-            123,         // port
-            'foo_user',  // user
+            'foo_host', // host
+            123, // port
+            'foo_user', // user
             'foo_password', // password
-            '/vhost',    // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            3,           // connection timeout
-            3,           // read write timeout
-            null,        // context
-            false,       // keepalive
-            0,           // heartbeat
+            '/vhost', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            3, // connection timeout
+            3, // read write timeout
+            null, // context
+            false, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -147,20 +147,20 @@ 
         $instance = $factory->createConnection();
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
         $this->assertEquals(array(
-            'bar_host',  // host
-            321,         // port
-            'bar_user',  // user
+            'bar_host', // host
+            321, // port
+            'bar_user', // user
             'bar_password', // password
-            'whost',     // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            6,           // connection timeout
-            6,           // read write timeout
-            null,        // context
-            true,        // keepalive
-            0,           // heartbeat
+            'whost', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            6, // connection timeout
+            6, // read write timeout
+            null, // context
+            true, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -177,20 +177,20 @@ 
         $instance = $factory->createConnection();
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
         $this->assertEquals(array(
-            'hoast',     // host
-            10000,       // port
-            'usera',     // user
-            'apass',     // password
-            'v/host',    // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            6,           // connection timeout
-            6,           // read write timeout
-            null,        // context
-            true,        // keepalive
-            0,           // heartbeat
+            'hoast', // host
+            10000, // port
+            'usera', // user
+            'apass', // password
+            'v/host', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            6, // connection timeout
+            6, // read write timeout
+            null, // context
+            true, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -207,20 +207,20 @@ 
         $instance = $factory->createConnection();
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
         $this->assertEquals(array(
-            'host',     // host
-            321,        // port
-            'user',     // user
-            'pass',     // password
-            '',         // vhost
-            false,      // insist
+            'host', // host
+            321, // port
+            'user', // user
+            'pass', // password
+            '', // vhost
+            false, // insist
             "AMQPLAIN", // login method
-            null,       // login response
-            "en_US",    // locale
-            6,          // connection timeout
-            6,          // read write timeout
-            null,       // context
-            true,       // keepalive
-            0,          // heartbeat
+            null, // login response
+            "en_US", // locale
+            6, // connection timeout
+            6, // read write timeout
+            null, // context
+            true, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -253,19 +253,19 @@ 
         $this->assertEquals(array('ssl' => array('verify_peer' => false)), $options);
         $this->assertEquals(array(
             'ssl_host', // host
-            123,        // port
+            123, // port
             'ssl_user', // user
             'ssl_password', // password
-            '/ssl',      // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            3,           // connection timeout
-            3,           // read write timeout
-            null,        // context checked earlier
-            false,       // keepalive
-            0,           // heartbeat
+            '/ssl', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            3, // connection timeout
+            3, // read write timeout
+            null, // context checked earlier
+            false, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 
@@ -276,7 +276,7 @@ 
             ->method('getConnectionParameters')
             ->will($this->returnValue(
                 array(
-                    'constructor_args' => array(1,2,3,4)
+                    'constructor_args' => array(1, 2, 3, 4)
                 )
             ));
         $factory = new AMQPConnectionFactory(
@@ -288,7 +288,7 @@ 
         /** @var AMQPConnection $instance */
         $instance = $factory->createConnection();
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
-        $this->assertEquals(array(1,2,3,4), $instance->constructParams);
+        $this->assertEquals(array(1, 2, 3, 4), $instance->constructParams);
     }
 
     public function testConnectionsParametersProvider()
@@ -315,20 +315,20 @@ 
         $instance = $factory->createConnection();
         $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
         $this->assertEquals(array(
-            '1.2.3.4',   // host
-            5678,        // port
-            'admin',     // user
-            'admin',     // password
-            'foo',       // vhost
-            false,       // insist
-            "AMQPLAIN",  // login method
-            null,        // login response
-            "en_US",     // locale
-            3,           // connection timeout
-            3,           // read write timeout
-            null,        // context
-            false,       // keepalive
-            0,           // heartbeat
+            '1.2.3.4', // host
+            5678, // port
+            'admin', // user
+            'admin', // password
+            'foo', // vhost
+            false, // insist
+            "AMQPLAIN", // login method
+            null, // login response
+            "en_US", // locale
+            3, // connection timeout
+            3, // read write timeout
+            null, // context
+            false, // keepalive
+            0, // heartbeat
         ), $instance->constructParams);
     }
 

Tests/RabbitMq/RpcServerTest.php

Spacing +1 added lines, -1 removed lines

@@ -16,7 +16,7 @@
             ->disableOriginalConstructor()
             ->getMock();
         $message = $this->getMockBuilder('\PhpAmqpLib\Message\AMQPMessage')
-            ->setMethods( array('get'))
+            ->setMethods(array('get'))
             ->getMock();
         $message->delivery_info = array(
             'channel' => $this->getMockBuilder('\PhpAmqpLib\Channel\AMQPChannel')

Tests/RabbitMq/BindingTest.php

Spacing +2 added lines, -2 removed lines

@@ -46,7 +46,7 @@ 
         $key = 'example_key';
         $ch->expects($this->once())
             ->method('queue_bind')
-            ->will($this->returnCallback(function ($d, $s, $k, $n, $a) use ($destination, $source, $key) {
+            ->will($this->returnCallback(function($d, $s, $k, $n, $a) use ($destination, $source, $key) {
                 Assert::assertSame($destination, $d);
                 Assert::assertSame($source, $s);
                 Assert::assertSame($key, $k);
@@ -71,7 +71,7 @@ 
         $key = 'example_key';
         $ch->expects($this->once())
             ->method('exchange_bind')
-            ->will($this->returnCallback(function ($d, $s, $k, $n, $a) use ($destination, $source, $key) {
+            ->will($this->returnCallback(function($d, $s, $k, $n, $a) use ($destination, $source, $key) {
                 Assert::assertSame($destination, $d);
                 Assert::assertSame($source, $s);
                 Assert::assertSame($key, $k);

DependencyInjection/OldSoundRabbitMqExtension.php

Spacing +3 added lines, -3 removed lines

@@ -37,7 +37,7 @@ 
     {
         $this->container = $container;
 
-        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__ . '/../Resources/config')));
+        $loader = new XmlFileLoader($this->container, new FileLocator(array(__DIR__.'/../Resources/config')));
         $loader->load('rabbitmq.xml');
 
         $configuration = $this->getConfiguration($configs, $container);
@@ -250,7 +250,7 @@ 
 
             if (empty($consumer['queues']) && empty($consumer['queues_provider'])) {
                 throw new InvalidConfigurationException(
-                    "Error on loading $key multiple consumer. " .
+                    "Error on loading $key multiple consumer. ".
                     "Either 'queues' or 'queues_provider' parameters should be defined."
                 );
             }
@@ -330,7 +330,7 @@ 
 
             if (empty($consumer['queue_options_provider'])) {
                 throw new InvalidConfigurationException(
-                    "Error on loading $key dynamic consumer. " .
+                    "Error on loading $key dynamic consumer. ".
                     "'queue_provider' parameter should be defined."
                 );
             }

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;
         };
     }