@@ -180,8 +180,9 @@ |
||
180 | 180 | */ |
181 | 181 | public function put(Workflow $workflow) |
182 | 182 | { |
183 | - if ($this->dispatcher) |
|
184 | - $this->dispatcher->dispatch(new CommandEvent($this, ['workflow' => $workflow]), CommandEvent::PUT); |
|
183 | + if ($this->dispatcher) { |
|
184 | + $this->dispatcher->dispatch(new CommandEvent($this, ['workflow' => $workflow]), CommandEvent::PUT); |
|
185 | + } |
|
185 | 186 | |
186 | 187 | return $this->pheanstalk->put($workflow); |
187 | 188 | } |
@@ -92,7 +92,7 @@ |
||
92 | 92 | $this->data['tubes'] = []; |
93 | 93 | /** @var Tube $tube */ |
94 | 94 | foreach ($tubes as $tube) { |
95 | - if(strpos($tube->getName(), '@')) |
|
95 | + if (strpos($tube->getName(), '@')) |
|
96 | 96 | continue; |
97 | 97 | // Fetch next ready job and next buried job for this tube |
98 | 98 | $stats = $pheanstalk->statsTube($tube); |
@@ -92,8 +92,9 @@ |
||
92 | 92 | $this->data['tubes'] = []; |
93 | 93 | /** @var Tube $tube */ |
94 | 94 | foreach ($tubes as $tube) { |
95 | - if(strpos($tube->getName(), '@')) |
|
96 | - continue; |
|
95 | + if(strpos($tube->getName(), '@')) { |
|
96 | + continue; |
|
97 | + } |
|
97 | 98 | // Fetch next ready job and next buried job for this tube |
98 | 99 | $stats = $pheanstalk->statsTube($tube); |
99 | 100 | $this->data['tubes'][] = [ |
@@ -61,7 +61,7 @@ |
||
61 | 61 | $pheanstalk['port'], |
62 | 62 | $pheanstalk['timeout'] |
63 | 63 | ]; |
64 | - $isDefault = $pheanstalk['default']; |
|
64 | + $isDefault = $pheanstalk['default']; |
|
65 | 65 | |
66 | 66 | # @see https://github.com/armetiz/pyrowmanPheanstalkBundle/issues/61 |
67 | 67 | $pheanstalkDef = clone $container->getDefinition($pheanstalk['proxy']); |
@@ -43,7 +43,7 @@ discard block |
||
43 | 43 | */ |
44 | 44 | private function configureLogListener(ContainerBuilder $container, array $config): void |
45 | 45 | { |
46 | - if(false === $container->has('logger')) { |
|
46 | + if (false === $container->has('logger')) { |
|
47 | 47 | return; |
48 | 48 | } |
49 | 49 | // Create a connection locator that will reference all existing connection |
@@ -81,7 +81,7 @@ discard block |
||
81 | 81 | */ |
82 | 82 | private function configureProfiler(ContainerBuilder $container, array $config): void |
83 | 83 | { |
84 | - if(false === $config['profiler']['enabled']) { |
|
84 | + if (false === $config['profiler']['enabled']) { |
|
85 | 85 | return; |
86 | 86 | } |
87 | 87 | // Setup the data collector service for Symfony profiler |