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