contamobi / CmobiRabbitmqBundle

Transport/Rpc/RpcQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -29,7 +29,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $response = $this->getQueueService()->handle($message);
 
             $amqpResponse = new CmobiAMQPMessage(

Transport/PubSub/SubscriberQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $this->getQueueService()->handle($message);
         };
     }

Transport/PubSub/ExchangeType.php

Spacing +1 added lines, -1 removed lines

@@ -5,6 +5,6 @@
 class ExchangeType
 {
     const FANOUT = 'fanout';
-    const DIRECT  = 'direct';
+    const DIRECT = 'direct';
     const TOPIC = 'topic';
 }
\ No newline at end of file

Transport/Worker/WorkerQueueCallback.php

Spacing +1 added lines, -1 removed lines

@@ -28,7 +28,7 @@
      */
     public function toClosure()
     {
-        return function (AMQPMessage $message) {
+        return function(AMQPMessage $message) {
             $this->getQueueService()->handle($message);
 
             $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']);

Tests/Transport/Rpc/RpcServerBuilderTest.php

Spacing +1 added lines, -1 removed lines

@@ -48,7 +48,7 @@
             ->disableOriginalConstructor()
             ->getMock();
 
-        $channelMock =  $this->getMockBuilder(CmobiAMQPChannel::class)
+        $channelMock = $this->getMockBuilder(CmobiAMQPChannel::class)
             ->disableOriginalConstructor()
             ->getMock();
         $channelMock->expects($this->any())

Tests/Transport/PubSub/SubscriberBuilderTest.php

Indentation +1 added lines, -1 removed lines

@@ -45,7 +45,7 @@
     {
         $subscriberBuilder = new SubscriberBuilder(
             'test_exchange',
-             ExchangeType::FANOUT,
+                ExchangeType::FANOUT,
             $this->getConnectionManagerMock(),
             $this->getLoggerMock(),
             []

Spacing +1 added lines, -1 removed lines

@@ -76,7 +76,7 @@
             ->disableOriginalConstructor()
             ->getMock();
 
-        $channelMock =  $this->getMockBuilder(CmobiAMQPChannel::class)
+        $channelMock = $this->getMockBuilder(CmobiAMQPChannel::class)
             ->disableOriginalConstructor()
             ->getMock();
         $channelMock->expects($this->any())

Tests/Transport/Worker/WorkerBuilderTest.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,7 @@
             ->disableOriginalConstructor()
             ->getMock();
 
-        $channelMock =  $this->getMockBuilder(CmobiAMQPChannel::class)
+        $channelMock = $this->getMockBuilder(CmobiAMQPChannel::class)
             ->disableOriginalConstructor()
             ->getMock();
         $channelMock->expects($this->any())

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