LinioIT / queue

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