spiral / framework

src/Queue/src/Job/CallableJob.php

Braces +4 added lines, -2 removed lines

@@ -17,11 +17,13 @@
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        if (!isset($payload['callback'])) {
+        if (!isset($payload['callback']))
+        {
             throw new InvalidArgumentException('Payload `callback` key is required.');
         }
 
-        if (!$payload['callback'] instanceof \Closure) {
+        if (!$payload['callback'] instanceof \Closure)
+        {
             throw new InvalidArgumentException('Payload `callback` key value type should be a closure.');
         }
 

src/Queue/src/Job/ObjectJob.php

Braces +4 added lines, -2 removed lines

@@ -17,11 +17,13 @@
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        if (!isset($payload['object'])) {
+        if (!isset($payload['object']))
+        {
             throw new InvalidArgumentException('Payload `object` key is required.');
         }
 
-        if (!\is_object($payload['object'])) {
+        if (!\is_object($payload['object']))
+        {
             throw new InvalidArgumentException('Payload `object` key value type should be an object.');
         }
 

src/Queue/src/JobHandler.php

Braces +5 added lines, -2 removed lines

@@ -24,12 +24,15 @@
 
     public function handle(string $name, string $id, array $payload, array $context = []): void
     {
-        try {
+        try
+        {
             $this->invoker->invoke(
                 [$this, $this->getHandlerMethod()],
                 \array_merge(['payload' => $payload, 'id' => $id, 'context' => $context], $payload)
             );
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             $message = \sprintf('[%s] %s', $this::class, $e->getMessage());
             throw new JobException($message, (int)$e->getCode(), $e);
         }