eMAGTechLabs / RabbitMqBundle

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

Tests/RabbitMq/ConsumerTest.php

Spacing +13 added lines, -13 removed lines

@@ -49,7 +49,7 @@ 
         $amqpChannel = $this->prepareAMQPChannel();
         $consumer = $this->getConsumer($amqpConnection, $amqpChannel);
 
-        $callbackFunction = function () use ($processFlag) {
+        $callbackFunction = function() use ($processFlag) {
             return $processFlag;
         }; // Create a callback function with a return value set by the data provider.
         $consumer->setCallback($callbackFunction);
@@ -62,14 +62,14 @@ 
         if ($expectedMethod) {
             $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.
                 }));
 
             $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.
                 }));
         } else {
@@ -174,7 +174,7 @@ 
             ->with(null, false, $consumer->getIdleTimeout())
             ->will(
                 $this->returnCallback(
-                    function () use ($amqpChannel) {
+                    function() use ($amqpChannel) {
                         /** remove an element on each loop like ... simulate an ACK */
                         array_splice($amqpChannel->callbacks, 0, 1);
                     })
@@ -220,7 +220,7 @@ 
         $amqpChannel->expects($this->exactly(1))
             ->method('wait')
             ->with(null, false, $consumer->getIdleTimeout())
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the last activity date time
                 $consumer->setLastActivityDateTime(new \DateTime("-$waitTimeout seconds"));
                 throw new AMQPTimeoutException();
@@ -255,7 +255,7 @@ 
         $amqpChannel->expects($this->exactly(2))
             ->method('wait')
             ->with(null, false, $consumer->getIdleTimeout())
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the last activity date time
                 $consumer->setLastActivityDateTime(new \DateTime("-$waitTimeout seconds"));
                 throw new AMQPTimeoutException();
@@ -268,7 +268,7 @@ 
         $eventDispatcher->expects($this->at(1))
             ->method('dispatch')
             ->with($this->isInstanceOf(OnIdleEvent::class), OnIdleEvent::NAME)
-            ->willReturnCallback(function (OnIdleEvent $event, $eventName) {
+            ->willReturnCallback(function(OnIdleEvent $event, $eventName) {
                 $event->setForceStop(false);
 
                 return $event;
@@ -277,7 +277,7 @@ 
         $eventDispatcher->expects($this->at(3))
             ->method('dispatch')
             ->with($this->isInstanceOf(OnIdleEvent::class), OnIdleEvent::NAME)
-            ->willReturnCallback(function (OnIdleEvent $event, $eventName) {
+            ->willReturnCallback(function(OnIdleEvent $event, $eventName) {
                 $event->setForceStop(true);
 
                 return $event;
@@ -316,7 +316,7 @@ 
 
         $amqpChannel->expects($this->exactly(1))
             ->method('wait')
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the max execution date time
                 $consumer->setGracefulMaxExecutionDateTimeFromSecondsInTheFuture($waitTimeout * -1);
                 throw new AMQPTimeoutException();
@@ -383,8 +383,8 @@ 
 
         $amqpChannel->expects($this->exactly(2))
             ->method('wait')
-            ->with(null, false, $this->LessThanOrEqual($consumer->getTimeoutWait()) )
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->with(null, false, $this->LessThanOrEqual($consumer->getTimeoutWait()))
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // ensure max execution date time "counts down"
                 $consumer->setGracefulMaxExecutionDateTime(
                     $consumer->getGracefulMaxExecutionDateTime()->modify("-$waitTimeout seconds")
@@ -425,7 +425,7 @@ 
         $amqpChannel->expects($this->once())
             ->method('wait')
             ->with(null, false, $consumer->getGracefulMaxExecutionDateTime()->diff(new \DateTime())->s)
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the max execution date time
                 $consumer->setGracefulMaxExecutionDateTimeFromSecondsInTheFuture($waitTimeout * -1);
                 throw new AMQPTimeoutException();
@@ -463,7 +463,7 @@ 
         $amqpChannel->expects($this->once())
             ->method('wait')
             ->with(null, false, 10)
-            ->willReturnCallback(function ($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
+            ->willReturnCallback(function($allowedMethods, $nonBlocking, $waitTimeout) use ($consumer) {
                 // simulate time passing by moving the last activity date time
                 $consumer->setLastActivityDateTime(new \DateTime("-$waitTimeout seconds"));
                 throw new AMQPTimeoutException();

Tests/RabbitMq/MultipleConsumerTest.php

Spacing +3 added lines, -3 removed lines

@@ -310,14 +310,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.
             }));
     }
@@ -329,7 +329,7 @@ 
      */
     private function prepareCallback(?int $processFlag)
     {
-        return function ($msg) use ($processFlag) {
+        return function($msg) use ($processFlag) {
             return $processFlag;
         };
     }

Tests/RabbitMq/AMQPConnectionFactoryTest.php

Spacing +117 added lines, -117 removed lines

@@ -23,19 +23,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);
     }
 
@@ -51,18 +51,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);
     }
 
@@ -81,18 +81,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);
     }
 
@@ -113,20 +113,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);
     }
 
@@ -148,20 +148,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);
     }
 
@@ -178,20 +178,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);
     }
 
@@ -208,20 +208,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);
     }
 
@@ -254,19 +254,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);
     }
 
@@ -277,7 +277,7 @@ 
             ->method('getConnectionParameters')
             ->will($this->returnValue(
                 array(
-                    'constructor_args' => array(1,2,3,4)
+                    'constructor_args' => array(1, 2, 3, 4)
                 )
             ));
         $factory = new AMQPConnectionFactory(
@@ -289,7 +289,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(): void
@@ -316,20 +316,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);
     }
 

RabbitMq/MultipleConsumer.php

Spacing +2 added lines, -2 removed lines

@@ -61,7 +61,7 @@ 
             //PHP 5.3 Compliant
             $currentObject = $this;
 
-            $this->getChannel()->basic_consume($name, $this->getQueueConsumerTag($name), false, false, false, false, function (AMQPMessage $msg) use($currentObject, $name) {
+            $this->getChannel()->basic_consume($name, $this->getQueueConsumerTag($name), false, false, false, false, function(AMQPMessage $msg) use($currentObject, $name) {
                 $currentObject->processQueueMessage($name, $msg);
             });
         }
@@ -70,7 +70,7 @@ 
     protected function queueDeclare(): void
     {
         foreach ($this->queues as $name => $options) {
-            list($queueName, ,) = $this->getChannel()->queue_declare(
+            list($queueName,,) = $this->getChannel()->queue_declare(
                 $name, $options['passive'],
                 $options['durable'], $options['exclusive'],
                 $options['auto_delete'], $options['nowait'],

RabbitMq/AmqpPartsHolder.php

Indentation +13 added lines, -13 removed lines

@@ -5,21 +5,21 @@
 class AmqpPartsHolder
 {
     /** @var array */
-	protected $parts;
+    protected $parts;
 
-	public function __construct()
-	{
-		$this->parts = array();
-	}
+    public function __construct()
+    {
+        $this->parts = array();
+    }
 
-	public function addPart(string $type, BaseAmqp $part): void
-	{
-		$this->parts[$type][] = $part;
-	}
+    public function addPart(string $type, BaseAmqp $part): void
+    {
+        $this->parts[$type][] = $part;
+    }
 
-	public function getParts(string $type): array
-	{
+    public function getParts(string $type): array
+    {
         $type = (string) $type;
-		return isset($this->parts[$type]) ? $this->parts[$type] : array();
-	}
+        return isset($this->parts[$type]) ? $this->parts[$type] : array();
+    }
 }

RabbitMq/BatchConsumer.php

Spacing +1 added lines, -1 removed lines

@@ -263,7 +263,7 @@
     private function addMessage(AMQPMessage $message): void
     {
         $this->batchCounter++;
-        $this->messages[(int)$message->delivery_info['delivery_tag']] = $message;
+        $this->messages[(int) $message->delivery_info['delivery_tag']] = $message;
     }
 
     private function getMessage(int $deliveryTag): ?AMQPMessage

RabbitMq/Binding.php

Indentation +2 added lines, -2 removed lines

@@ -34,12 +34,12 @@
      */
     protected $arguments;
 
-     public function getExchange(): string
+        public function getExchange(): string
     {
         return $this->exchange;
     }
 
-     public function setExchange(string $exchange): void
+        public function setExchange(string $exchange): void
     {
         $this->exchange = $exchange;
     }

RabbitMq/RpcServer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
     public function initServer(string $name): void
     {
         $this->setExchangeOptions(array('name' => $name, 'type' => 'direct'));
-        $this->setQueueOptions(array('name' => $name . '-queue'));
+        $this->setQueueOptions(array('name' => $name.'-queue'));
     }
 
     public function processMessage(AMQPMessage $msg): void
@@ -25,7 +25,7 @@ 
             $this->consumed++;
             $this->maybeStopConsumer();
         } catch (\Exception $e) {
-            $this->sendReply('error: ' . $e->getMessage(), $msg->get('reply_to'), $msg->get('correlation_id'));
+            $this->sendReply('error: '.$e->getMessage(), $msg->get('reply_to'), $msg->get('correlation_id'));
         }
     }