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