| @@ -28,7 +28,7 @@ discard block | ||
| 28 | 28 | |
| 29 | 29 | public function getSerializer(string $jobType): SerializerInterface | 
| 30 | 30 |      { | 
| 31 | -        if (!$this->hasSerializer($jobType)) { | |
| 31 | +        if (!$this->hasSerializer($jobType)){ | |
| 32 | 32 | return $this->default; | 
| 33 | 33 | } | 
| 34 | 34 | |
| @@ -37,7 +37,7 @@ discard block | ||
| 37 | 37 | |
| 38 | 38 | public function addSerializer(string $jobType, SerializerInterface $serializer): void | 
| 39 | 39 |      { | 
| 40 | -        if (!$this->hasSerializer($jobType)) { | |
| 40 | +        if (!$this->hasSerializer($jobType)){ | |
| 41 | 41 | $this->serializers[$jobType] = $serializer; | 
| 42 | 42 | } | 
| 43 | 43 | } | 
| @@ -28,7 +28,8 @@ discard block | ||
| 28 | 28 | |
| 29 | 29 | public function getSerializer(string $jobType): SerializerInterface | 
| 30 | 30 |      { | 
| 31 | -        if (!$this->hasSerializer($jobType)) { | |
| 31 | + if (!$this->hasSerializer($jobType)) | |
| 32 | +        { | |
| 32 | 33 | return $this->default; | 
| 33 | 34 | } | 
| 34 | 35 | |
| @@ -37,7 +38,8 @@ discard block | ||
| 37 | 38 | |
| 38 | 39 | public function addSerializer(string $jobType, SerializerInterface $serializer): void | 
| 39 | 40 |      { | 
| 40 | -        if (!$this->hasSerializer($jobType)) { | |
| 41 | + if (!$this->hasSerializer($jobType)) | |
| 42 | +        { | |
| 41 | 43 | $this->serializers[$jobType] = $serializer; | 
| 42 | 44 | } | 
| 43 | 45 | } | 
| @@ -61,12 +61,12 @@ discard block | ||
| 61 | 61 | $config = $container->get(QueueConfig::class); | 
| 62 | 62 | $serializersRegistry = $container->get(SerializerRegistryInterface::class); | 
| 63 | 63 | |
| 64 | -            foreach ($config->getRegistryHandlers() as $jobType => $handler) { | |
| 64 | +            foreach ($config->getRegistryHandlers() as $jobType => $handler){ | |
| 65 | 65 | $registry->setHandler($jobType, $handler); | 
| 66 | 66 | } | 
| 67 | 67 | |
| 68 | -            foreach ($config->getRegistrySerializers() as $jobType => $serializer) { | |
| 69 | -                if ($serializer instanceof Container\Autowire || \is_string($serializer)) { | |
| 68 | +            foreach ($config->getRegistrySerializers() as $jobType => $serializer){ | |
| 69 | +                if ($serializer instanceof Container\Autowire || \is_string($serializer)){ | |
| 70 | 70 | $serializer = $container->get($serializer); | 
| 71 | 71 | } | 
| 72 | 72 | $serializersRegistry->addSerializer($jobType, $serializer); | 
| @@ -96,7 +96,7 @@ discard block | ||
| 96 | 96 |      { | 
| 97 | 97 | $default = $config->getDefaultSerializer(); | 
| 98 | 98 | |
| 99 | -        if ($default instanceof Container\Autowire || \is_string($default)) { | |
| 99 | +        if ($default instanceof Container\Autowire || \is_string($default)){ | |
| 100 | 100 | $default = $container->get($default); | 
| 101 | 101 | } | 
| 102 | 102 | |
| @@ -61,12 +61,15 @@ discard block | ||
| 61 | 61 | $config = $container->get(QueueConfig::class); | 
| 62 | 62 | $serializersRegistry = $container->get(SerializerRegistryInterface::class); | 
| 63 | 63 | |
| 64 | -            foreach ($config->getRegistryHandlers() as $jobType => $handler) { | |
| 64 | + foreach ($config->getRegistryHandlers() as $jobType => $handler) | |
| 65 | +            { | |
| 65 | 66 | $registry->setHandler($jobType, $handler); | 
| 66 | 67 | } | 
| 67 | 68 | |
| 68 | -            foreach ($config->getRegistrySerializers() as $jobType => $serializer) { | |
| 69 | -                if ($serializer instanceof Container\Autowire || \is_string($serializer)) { | |
| 69 | + foreach ($config->getRegistrySerializers() as $jobType => $serializer) | |
| 70 | +            { | |
| 71 | + if ($serializer instanceof Container\Autowire || \is_string($serializer)) | |
| 72 | +                { | |
| 70 | 73 | $serializer = $container->get($serializer); | 
| 71 | 74 | } | 
| 72 | 75 | $serializersRegistry->addSerializer($jobType, $serializer); | 
| @@ -96,7 +99,8 @@ discard block | ||
| 96 | 99 |      { | 
| 97 | 100 | $default = $config->getDefaultSerializer(); | 
| 98 | 101 | |
| 99 | -        if ($default instanceof Container\Autowire || \is_string($default)) { | |
| 102 | + if ($default instanceof Container\Autowire || \is_string($default)) | |
| 103 | +        { | |
| 100 | 104 | $default = $container->get($default); | 
| 101 | 105 | } | 
| 102 | 106 | |
| @@ -12,7 +12,7 @@ discard block | ||
| 12 | 12 |      { | 
| 13 | 13 | $result = \serialize($payload); | 
| 14 | 14 | |
| 15 | -        if ($result === false) { | |
| 15 | +        if ($result === false){ | |
| 16 | 16 |              throw new SerializationException('Failed to serialize data.'); | 
| 17 | 17 | } | 
| 18 | 18 | |
| @@ -23,7 +23,7 @@ discard block | ||
| 23 | 23 |      { | 
| 24 | 24 | $result = \unserialize($payload); | 
| 25 | 25 | |
| 26 | -        if ($result === false) { | |
| 26 | +        if ($result === false){ | |
| 27 | 27 |              throw new SerializationException('Failed to unserialize data.'); | 
| 28 | 28 | } | 
| 29 | 29 | |
| @@ -12,7 +12,8 @@ discard block | ||
| 12 | 12 |      { | 
| 13 | 13 | $result = \serialize($payload); | 
| 14 | 14 | |
| 15 | -        if ($result === false) { | |
| 15 | + if ($result === false) | |
| 16 | +        { | |
| 16 | 17 |              throw new SerializationException('Failed to serialize data.'); | 
| 17 | 18 | } | 
| 18 | 19 | |
| @@ -23,7 +24,8 @@ discard block | ||
| 23 | 24 |      { | 
| 24 | 25 | $result = \unserialize($payload); | 
| 25 | 26 | |
| 26 | -        if ($result === false) { | |
| 27 | + if ($result === false) | |
| 28 | +        { | |
| 27 | 29 |              throw new SerializationException('Failed to unserialize data.'); | 
| 28 | 30 | } | 
| 29 | 31 | |