@@ -148,6 +148,7 @@ discard block |
||
| 148 | 148 | /** |
| 149 | 149 | * @param string $crcCacheKey |
| 150 | 150 | * @param integer|null $newFoundPriority |
| 151 | + * @param string $foundJobCacheKey |
|
| 151 | 152 | */ |
| 152 | 153 | protected function finishBatchFoundJob(Job $foundJob, $foundJobCacheKey, $crcCacheKey, $newFoundWhen, $newFoundPriority) |
| 153 | 154 | { |
@@ -170,6 +171,7 @@ discard block |
||
| 170 | 171 | |
| 171 | 172 | /** |
| 172 | 173 | * @param boolean $adjust |
| 174 | + * @param string $crcCacheKey |
|
| 173 | 175 | */ |
| 174 | 176 | protected function addFoundJob($adjust, Job $foundJob, $foundJobCacheKey, $crcCacheKey) |
| 175 | 177 | { |
@@ -190,6 +192,7 @@ discard block |
||
| 190 | 192 | |
| 191 | 193 | /** |
| 192 | 194 | * @param string $queue |
| 195 | + * @param boolean $adjust |
|
| 193 | 196 | */ |
| 194 | 197 | private function adjustJob($adjust, $queue, Job $foundJob, $foundJobCacheKey, $crcCacheKey, $zScore) |
| 195 | 198 | { |
@@ -364,7 +367,7 @@ discard block |
||
| 364 | 367 | * |
| 365 | 368 | * @throws UnsupportedException |
| 366 | 369 | * |
| 367 | - * @return \Dtc\QueueBundle\Model\Job|null |
|
| 370 | + * @return Job|null |
|
| 368 | 371 | */ |
| 369 | 372 | public function getJob($workerName = null, $methodName = null, $prioritize = true, $runId = null) |
| 370 | 373 | { |
@@ -504,7 +504,7 @@ |
||
| 504 | 504 | |
| 505 | 505 | return $node; |
| 506 | 506 | })->end() |
| 507 | - ->validate()->ifTrue(function ($node) { |
|
| 507 | + ->validate()->ifTrue(function($node) { |
|
| 508 | 508 | if (isset($node['ssl_options']) && !$node['ssl']) { |
| 509 | 509 | return true; |
| 510 | 510 | } |