spiral / framework

src/Queue/src/QueueManager.php

Spacing +6 added lines, -6 removed lines

@@ -24,7 +24,7 @@ 
         private readonly ContainerInterface $container,
         private readonly FactoryInterface $factory,
         private readonly ?EventDispatcherInterface $dispatcher = null
-    ) {
+    ){
     }
 
     public function getConnection(?string $name = null): QueueInterface
@@ -33,7 +33,7 @@ 
         // 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 +48,7 @@ 
     {
         $config = $this->config->getConnection($name);
 
-        try {
+        try{
             $driver = $this->factory->make($config['driver'], $config);
 
             $core = new InterceptableCore(
@@ -56,8 +56,8 @@ 
                 $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 +66,7 @@ 
             }
 
             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`',

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

Spacing +9 added lines, -9 removed lines

@@ -48,7 +48,7 @@ 
 
     public function __construct(
         private readonly ConfiguratorInterface $config
-    ) {
+    ){
     }
 
     public function init(
@@ -66,11 +66,11 @@ 
             $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);
             }
         });
@@ -79,7 +79,7 @@ 
     /**
      * @param class-string<CoreInterceptorInterface>|CoreInterceptorInterface|Autowire $interceptor
      */
-    public function addConsumeInterceptor(string|CoreInterceptorInterface|Autowire $interceptor): void
+    public function addConsumeInterceptor(string | CoreInterceptorInterface | Autowire $interceptor): void
     {
         $this->config->modify(
             QueueConfig::CONFIG,
@@ -90,7 +90,7 @@ 
     /**
      * @param class-string<CoreInterceptorInterface>|CoreInterceptorInterface|Autowire $interceptor
      */
-    public function addPushInterceptor(string|CoreInterceptorInterface|Autowire $interceptor): void
+    public function addPushInterceptor(string | CoreInterceptorInterface | Autowire $interceptor): void
     {
         $this->config->modify(
             QueueConfig::CONFIG,
@@ -115,7 +115,7 @@ 
         ContainerInterface $container,
         FactoryInterface $factory,
         ContainerRegistry $registry
-    ) {
+    ){
         return new QueueRegistry($container, $factory, $registry);
     }
 
@@ -128,10 +128,10 @@ 
     ): 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);
             }
 

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