@@ -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) { |
@@ -52,7 +52,7 @@ discard block |
||
52 | 52 | |
53 | 53 | /** |
54 | 54 | * @param ContainerBuilder $container |
55 | - * @param array $jobManagerRef |
|
55 | + * @param Reference[] $jobManagerRef |
|
56 | 56 | * @param string $jobClass |
57 | 57 | */ |
58 | 58 | protected function setupTaggedServices(ContainerBuilder $container, Definition $definition, array $jobManagerRef, $jobClass) |
@@ -142,7 +142,7 @@ discard block |
||
142 | 142 | /** |
143 | 143 | * @param ContainerBuilder $container |
144 | 144 | * @param array $arguments |
145 | - * @param $class |
|
145 | + * @param string $class |
|
146 | 146 | */ |
147 | 147 | protected function setupRabbitMQOptions(ContainerBuilder $container, array &$arguments, &$class) |
148 | 148 | { |
@@ -254,6 +254,10 @@ discard block |
||
254 | 254 | return $jobClass; |
255 | 255 | } |
256 | 256 | |
257 | + /** |
|
258 | + * @param string $type |
|
259 | + * @param string $className |
|
260 | + */ |
|
257 | 261 | protected function getRunArchiveClass(ContainerBuilder $container, $type, $className) |
258 | 262 | { |
259 | 263 | $runArchiveClass = $container->hasParameter('dtc_queue.class_'.$type) ? $container->getParameter('dtc_queue.class_'.$type) : null; |
@@ -293,7 +297,6 @@ discard block |
||
293 | 297 | } |
294 | 298 | |
295 | 299 | /** |
296 | - * @param string|null $jobArchiveClass |
|
297 | 300 | * |
298 | 301 | * @throws \Exception |
299 | 302 | */ |