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