LinioIT / queue

src/Queue/Adapter/RabbitAdapter.php

Spacing +2 added lines, -2 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue\Adapter;
 
@@ -37,7 +37,7 @@ 
     {
         $this->getChannel()->queue_declare($job->getQueue(), true, $job->isPersistent(), false, false);
         $this->getChannel()->basic_qos(null, 1, null);
-        $this->getChannel()->basic_consume($job->getQueue(), '', false, false, false, false, function ($message) use ($job) {
+        $this->getChannel()->basic_consume($job->getQueue(), '', false, false, false, false, function($message) use ($job) {
             $job->setPayload($message->body);
             $job->perform();
 

src/Queue/Adapter/NullAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue\Adapter;
 

src/Queue/Provider/QueueServiceProvider.php

Spacing +3 added lines, -3 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue\Provider;
 
@@ -16,14 +16,14 @@ 
             $container['queue.adapter_name'] = 'null';
         }
 
-        $container['queue.adapter'] = $container->factory(function ($container) {
+        $container['queue.adapter'] = $container->factory(function($container) {
             $adapterFactory = new AdapterFactory();
             $adapter = $adapterFactory->getAdapter($container['queue.adapter_name'], $container['queue.adapter_options']);
 
             return $adapter;
         });
 
-        $container['queue.service'] = function ($container) {
+        $container['queue.service'] = function($container) {
             $queueService = new QueueService();
             $queueService->setAdapter($container['queue.adapter']);
             $queueService->setLogger($container['monolog']);

src/Queue/QueueAware.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue;
 

src/Queue/AdapterInterface.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue;
 

src/Queue/AdapterFactory.php

Spacing +2 added lines, -2 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue;
 
@@ -12,7 +12,7 @@ 
         $adapterClass = sprintf('%s\\Adapter\\%sAdapter', __NAMESPACE__, Inflector::pascalize($adapterName));
 
         if (!class_exists($adapterClass)) {
-            throw new \InvalidArgumentException('Adapter class does not exist: ' . $adapterClass);
+            throw new \InvalidArgumentException('Adapter class does not exist: '.$adapterClass);
         }
 
         $adapter = new $adapterClass($adapterConfig);

src/Queue/PersistentJob.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue;
 

src/Queue/Job.php

Spacing +1 added lines, -1 removed lines

@@ -1,5 +1,5 @@
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue;
 

src/Queue/QueueService.php

Spacing +2 added lines, -2 removed lines

@@ -1,5 +1,5 @@ 
 <?php
-declare(strict_types=1);
+declare(strict_types = 1);
 
 namespace Linio\Component\Queue;
 
@@ -24,7 +24,7 @@ 
             $this->prepare($job);
             $this->adapter->add($job);
         } catch (\Exception $e) {
-            $this->logger->error('[Queue] An error has occurred when adding job: ' . $e->getMessage(), (array) $e);
+            $this->logger->error('[Queue] An error has occurred when adding job: '.$e->getMessage(), (array) $e);
 
             return false;
         }