@@ -208,6 +208,7 @@ discard block |
||
208 | 208 | * @param string $workerName |
209 | 209 | * @param string $methodName |
210 | 210 | * @param bool $prioritize |
211 | + * @param integer $runId |
|
211 | 212 | * |
212 | 213 | * @return \Dtc\QueueBundle\Model\Job |
213 | 214 | */ |
@@ -233,8 +234,8 @@ discard block |
||
233 | 234 | } |
234 | 235 | |
235 | 236 | /** |
236 | - * @param null $workerName |
|
237 | - * @param null $methodName |
|
237 | + * @param string|null $workerName |
|
238 | + * @param string|null $methodName |
|
238 | 239 | * @param bool $prioritize |
239 | 240 | * |
240 | 241 | * @return Builder |
@@ -239,6 +239,7 @@ discard block |
||
239 | 239 | * @param string $workerName |
240 | 240 | * @param string $methodName |
241 | 241 | * @param bool $prioritize |
242 | + * @param integer $runId |
|
242 | 243 | * |
243 | 244 | * @return Job|null |
244 | 245 | */ |
@@ -255,8 +256,8 @@ discard block |
||
255 | 256 | } |
256 | 257 | |
257 | 258 | /** |
258 | - * @param null $workerName |
|
259 | - * @param null $methodName |
|
259 | + * @param string|null $workerName |
|
260 | + * @param string|null $methodName |
|
260 | 261 | * @param bool $prioritize |
261 | 262 | * |
262 | 263 | * @return QueryBuilder |
@@ -332,7 +333,7 @@ discard block |
||
332 | 333 | * |
333 | 334 | * @param \Dtc\QueueBundle\Model\Job $job |
334 | 335 | * |
335 | - * @return mixed|null |
|
336 | + * @return null|Job |
|
336 | 337 | */ |
337 | 338 | public function updateNearestBatch(\Dtc\QueueBundle\Model\Job $job) |
338 | 339 | { |
@@ -361,6 +362,10 @@ discard block |
||
361 | 362 | return $existingJob; |
362 | 363 | } |
363 | 364 | |
365 | + /** |
|
366 | + * @param integer $newPriority |
|
367 | + * @param null|\DateTime $newWhenAt |
|
368 | + */ |
|
364 | 369 | protected function updateBatchJob(Job $existingJob, $newPriority, $newWhenAt) |
365 | 370 | { |
366 | 371 | $existingPriority = $existingJob->getPriority(); |