spiral / framework

src/Queue/src/DefaultSerializer.php

Spacing +4 added lines, -4 removed lines

@@ -18,9 +18,9 @@ 
      */
     public function serialize(array $payload): string
     {
-        try {
+        try{
             return serialize($payload);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new SerializationException($e->getMessage(), (int)$e->getCode(), $e);
         }
     }
@@ -30,9 +30,9 @@ 
      */
     public function deserialize(string $payload): array
     {
-        try {
+        try{
             return (array)unserialize($payload);
-        } catch (\Throwable $e) {
+        }catch (\Throwable $e){
             throw new SerializationException($e->getMessage(), (int)$e->getCode(), $e);
         }
     }

src/Queue/src/SerializerRegistry.php

Spacing +2 added lines, -2 removed lines

@@ -28,7 +28,7 @@ 
 
     public function getSerializer(string $jobType): SerializerInterface
     {
-        if (!$this->hasSerializer($jobType)) {
+        if (!$this->hasSerializer($jobType)){
             return $this->default;
         }
 
@@ -37,7 +37,7 @@ 
 
     public function addSerializer(string $jobType, SerializerInterface $serializer): void
     {
-        if (!$this->hasSerializer($jobType)) {
+        if (!$this->hasSerializer($jobType)){
             $this->serializers[$jobType] = $serializer;
         }
     }

src/Queue/src/PhpSerializer.php

Spacing +2 added lines, -2 removed lines

@@ -12,7 +12,7 @@ 
     {
         $result = \serialize($payload);
 
-        if ($result === false) {
+        if ($result === false){
             throw new SerializationException('Failed to serialize data.');
         }
 
@@ -23,7 +23,7 @@ 
     {
         $result = \unserialize($payload);
 
-        if ($result === false) {
+        if ($result === false){
             throw new SerializationException('Failed to unserialize data.');
         }
 

src/Queue/src/Bootloader/QueueBootloader.php

Spacing +4 added lines, -4 removed lines

@@ -62,12 +62,12 @@ 
             $config = $container->get(QueueConfig::class);
             $serializersRegistry = $container->get(SerializerRegistryInterface::class);
 
-            foreach ($config->getRegistryHandlers() as $jobType => $handler) {
+            foreach ($config->getRegistryHandlers() as $jobType => $handler){
                 $registry->setHandler($jobType, $handler);
             }
 
-            foreach ($config->getRegistrySerializers() as $jobType => $serializer) {
-                if ($serializer instanceof Autowire || \is_string($serializer)) {
+            foreach ($config->getRegistrySerializers() as $jobType => $serializer){
+                if ($serializer instanceof Autowire || \is_string($serializer)){
                     $serializer = $container->get($serializer);
                 }
                 $serializersRegistry->addSerializer($jobType, $serializer);
@@ -97,7 +97,7 @@ 
     {
         $default = $config->getDefaultSerializer();
 
-        if ($default instanceof Autowire || \is_string($default)) {
+        if ($default instanceof Autowire || \is_string($default)){
             $default = $container->get($default);
         }