spiral / framework

src/Queue/src/QueueManager.php

Braces +11 added lines, -5 removed lines

@@ -33,7 +33,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);
         }
 
@@ -48,7 +49,8 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try
+        {
             $driver = $this->factory->make($config['driver'], $config);
 
             $core = new InterceptableCore(
@@ -56,8 +58,10 @@ 
                 $this->dispatcher
             );
 
-            foreach ($this->config->getPushInterceptors() as $interceptor) {
-                if (\is_string($interceptor) || $interceptor instanceof Autowire) {
+            foreach ($this->config->getPushInterceptors() as $interceptor)
+            {
+                if (\is_string($interceptor) || $interceptor instanceof Autowire)
+                {
                     $interceptor = $this->container->get($interceptor);
                 }
 
@@ -66,7 +70,9 @@ 
             }
 
             return new Queue($core);
-        } 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/Bootloader/QueueBootloader.php

Braces +11 added lines, -5 removed lines

@@ -66,11 +66,13 @@ 
             $registry = $container->get(QueueRegistry::class);
             $config = $container->get(QueueConfig::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler)
+            {
                 $registry->setHandler($jobType, $handler);
             }
 
-            foreach ($config->getRegistrySerializers() as $jobType => $serializer) {
+            foreach ($config->getRegistrySerializers() as $jobType => $serializer)
+            {
                 $registry->setSerializer($jobType, $serializer);
             }
         });
@@ -128,10 +130,14 @@ 
     ): Handler {
         $core = new InterceptableCore($core, $dispatcher);
 
-        foreach ($config->getConsumeInterceptors() as $interceptor) {
-            if (\is_string($interceptor)) {
+        foreach ($config->getConsumeInterceptors() as $interceptor)
+        {
+            if (\is_string($interceptor))
+            {
                 $interceptor = $container->get($interceptor);
-            } elseif ($interceptor instanceof Autowire) {
+            }
+            elseif ($interceptor instanceof Autowire)
+            {
                 $interceptor = $interceptor->resolve($factory);
             }
 

src/Queue/tests/Core/QueueInjectorTest.php

Braces +2 added lines, -1 removed lines

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

src/Queue/src/Core/QueueInjector.php

Braces +15 added lines, -6 removed lines

@@ -23,19 +23,28 @@
 
     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) {
+                }
+                catch (InvalidArgumentException)
+                {
                     // Case when context doesn't match to configured connections
                     return $this->queueManager->getConnection();
                 }
             }
-        } catch (\Throwable $e) {
+        }
+        catch (\Throwable $e)
+        {
             throw new ContainerException(\sprintf("Can't inject the required queue. %s", $e->getMessage()), 0, $e);
         }