@@ -92,7 +92,7 @@ |
||
| 92 | 92 | $this->eventDispatcher->dispatch(Event::PRE_JOB, $event); |
| 93 | 93 | |
| 94 | 94 | $start = microtime(true); |
| 95 | - $handleException = function ($exception) use ($job) { |
|
| 95 | + $handleException = function($exception) use ($job) { |
|
| 96 | 96 | /** @var \Exception $exception */ |
| 97 | 97 | $exceptionMessage = get_class($exception)."\n".$exception->getCode().' - '.$exception->getMessage()."\n".$exception->getTraceAsString(); |
| 98 | 98 | $this->log('debug', "Failed: {$job->getClassName()}->{$job->getMethod()}"); |
@@ -33,7 +33,7 @@ |
||
| 33 | 33 | $total += count($this->jobs[$jobWorkerName]); |
| 34 | 34 | } |
| 35 | 35 | |
| 36 | - return array_sum(array_map(function ($jobs) { return count($jobs); }, $this->jobs)); |
|
| 36 | + return array_sum(array_map(function($jobs) { return count($jobs); }, $this->jobs)); |
|
| 37 | 37 | } |
| 38 | 38 | |
| 39 | 39 | public function getStatus() |
@@ -86,7 +86,7 @@ |
||
| 86 | 86 | } |
| 87 | 87 | |
| 88 | 88 | /** |
| 89 | - * @param int $erroredCount |
|
| 89 | + * @param integer $errorCount |
|
| 90 | 90 | * |
| 91 | 91 | * @return RetryableJob |
| 92 | 92 | */ |
@@ -117,6 +117,10 @@ |
||
| 117 | 117 | } |
| 118 | 118 | } |
| 119 | 119 | |
| 120 | + /** |
|
| 121 | + * @param string $workerName |
|
| 122 | + * @param string $method |
|
| 123 | + */ |
|
| 120 | 124 | protected function addWorkerNameCriterion(QueryBuilder $queryBuilder, $workerName = null, $method = null) |
| 121 | 125 | { |
| 122 | 126 | if (null !== $workerName) { |
@@ -3,7 +3,6 @@ |
||
| 3 | 3 | namespace Dtc\QueueBundle\Command; |
| 4 | 4 | |
| 5 | 5 | use Dtc\QueueBundle\Model\Job; |
| 6 | -use Dtc\QueueBundle\Model\Run; |
|
| 7 | 6 | use Dtc\QueueBundle\Run\Loop; |
| 8 | 7 | use Dtc\QueueBundle\Util\Util; |
| 9 | 8 | use Psr\Log\LoggerInterface; |
@@ -7,7 +7,7 @@ |
||
| 7 | 7 | trait CommonTrait |
| 8 | 8 | { |
| 9 | 9 | /** |
| 10 | - * @param \Doctrine\ODM\MongoDB\DocumentManager $documentManager |
|
| 10 | + * @param \Doctrine\ODM\MongoDB\DocumentManager $entityManager |
|
| 11 | 11 | * @param string $objectName |
| 12 | 12 | * @param string $field |
| 13 | 13 | * @param \DateTime $olderThan |
@@ -94,7 +94,7 @@ discard block |
||
| 94 | 94 | |
| 95 | 95 | /** |
| 96 | 96 | * @param float $start |
| 97 | - * @param null|int $nanoSleep |
|
| 97 | + * @param integer $nanoSleep |
|
| 98 | 98 | * @param null|int $maxCount |
| 99 | 99 | * @param null|int $duration |
| 100 | 100 | */ |
@@ -124,9 +124,9 @@ discard block |
||
| 124 | 124 | } |
| 125 | 125 | |
| 126 | 126 | /** |
| 127 | - * @param $nanoSleep |
|
| 128 | - * @param $maxCount |
|
| 129 | - * @param $duration |
|
| 127 | + * @param integer $nanoSleep |
|
| 128 | + * @param null|integer $maxCount |
|
| 129 | + * @param null|integer $duration |
|
| 130 | 130 | * |
| 131 | 131 | * @throws \Exception |
| 132 | 132 | */ |
@@ -211,9 +211,9 @@ discard block |
||
| 211 | 211 | * Determine if the run loop is finished. |
| 212 | 212 | * |
| 213 | 213 | * @param $maxCount |
| 214 | - * @param $currentJob |
|
| 215 | - * @param int|null $duration |
|
| 214 | + * @param integer $currentJob |
|
| 216 | 215 | * @param \DateTime $endTime |
| 216 | + * @param boolean $noMoreJobsToRun |
|
| 217 | 217 | * |
| 218 | 218 | * @return bool |
| 219 | 219 | */ |
@@ -58,6 +58,7 @@ |
||
| 58 | 58 | * @param string $commandClass |
| 59 | 59 | * @param ContainerInterface $container |
| 60 | 60 | * @param array $params |
| 61 | + * @param integer $expectedResult |
|
| 61 | 62 | */ |
| 62 | 63 | protected function runCommandExpect($commandClass, ContainerInterface $container, array $params, $expectedResult) |
| 63 | 64 | { |
@@ -8,8 +8,6 @@ |
||
| 8 | 8 | class UtilTest extends TestCase |
| 9 | 9 | { |
| 10 | 10 | /** |
| 11 | - * @param string $varName |
|
| 12 | - * @param int $pow |
|
| 13 | 11 | */ |
| 14 | 12 | public function testValidateIntNull() |
| 15 | 13 | { |