@@ -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/LeezyPheanstalkBundle/issues/61 |
67 | 67 | $pheanstalkDef = clone $container->getDefinition($pheanstalk['proxy']); |