@@ -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 | |