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/Adapter/RabbitAdapter.php

Spacing +1 added lines, -1 removed lines

@@ -31,7 +31,7 @@
     {
         $this->getChannel()->queue_declare($job->getQueue(), true, $job->isPersistent(), false, false);
         $this->getChannel()->basic_qos(0, 1, false);
-        $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();
 

src/Queue/QueueService.php

Spacing +1 added lines, -1 removed lines

@@ -27,7 +27,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;
         }