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