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