LinioIT / queue

src/Queue/AdapterFactory.php

Spacing +1 added lines, -1 removed lines

@@ -13,7 +13,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);
         }
 
         return new $adapterClass($adapterConfig);

src/Queue/Provider/QueueServiceProvider.php

Spacing +2 added lines, -2 removed lines

@@ -17,13 +17,13 @@
             $container['queue.adapter_name'] = 'null';
         }
 
-        $container['queue.adapter'] = $container->factory(function ($container) {
+        $container['queue.adapter'] = $container->factory(function($container) {
             $adapterFactory = new AdapterFactory();
 
             return $adapterFactory->getAdapter($container['queue.adapter_name'], $container['queue.adapter_options']);
         });
 
-        $container['queue.service'] = function ($container) {
+        $container['queue.service'] = function($container) {
             $queueService = new QueueService();
             $queueService->setAdapter($container['queue.adapter']);
             $queueService->setLogger($container['monolog']);

src/Queue/Adapter/RabbitAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -38,7 +38,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): void {
+        $this->getChannel()->basic_consume($job->getQueue(), '', false, false, false, false, function($message) use ($job): void {
             $job->setPayload($message->body);
             $job->perform();