spiral / framework

src/Queue/tests/Core/QueueInjectorTest.php

Braces +2 added lines, -1 removed lines

@@ -86,7 +86,8 @@
                     'sync' => $this->defaultQueue,
                     'test' => new TestQueueClass(),
                 ][$name] ?? null;
-            if ($result === null) {
+            if ($result === null)
+            {
                 throw new NotFoundException();
             }
             return $result;

src/Queue/src/QueueManager.php

Braces +7 added lines, -3 removed lines

@@ -29,7 +29,8 @@ 
         // Replaces alias with real pipeline name
         $name = $this->config->getAliases()[$name] ?? $name;
 
-        if (!isset($this->pipelines[$name])) {
+        if (!isset($this->pipelines[$name]))
+        {
             $this->pipelines[$name] = $this->resolveConnection($name);
         }
 
@@ -44,9 +45,12 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             return $this->factory->make($config['driver'], $config);
-        } catch (ContainerException $e) {
+        }
+        catch (ContainerException $e)
+        {
             throw new Exception\NotSupportedDriverException(
                 \sprintf(
                     'Driver `%s` is not supported. Connection `%s` cannot be created. Reason: `%s`',

src/Queue/src/Core/QueueInjector.php

Braces +17 added lines, -7 removed lines

@@ -25,21 +25,30 @@ 
 
     public function createInjection(ReflectionClass $class, string $context = null): QueueInterface
     {
-        try {
-            if ($context === null) {
+        try
+        {
+            if ($context === null)
+            {
                 $connection = $this->queueManager->getConnection();
-            } else {
+            }
+            else
+            {
                 // Get Queue by context
-                try {
+                try
+                {
                     $connection = $this->queueManager->getConnection($context);
-                } catch (InvalidArgumentException $e) {
+                }
+                catch (InvalidArgumentException $e)
+                {
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
 
             $this->matchType($class, $context, $connection);
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new ContainerException(sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }
 
@@ -54,7 +63,8 @@ 
     private function matchType(ReflectionClass $class, string $context, QueueInterface $connection): void
     {
         $className = $class->getName();
-        if ($className !== QueueInterface::class && !$connection instanceof $className) {
+        if ($className !== QueueInterface::class && !$connection instanceof $className)
+        {
             throw new \RuntimeException(
                 \sprintf(
                     "The queue obtained by the context `%s` doesn't match the type `%s`.",