@@ -207,6 +207,9 @@ |
||
207 | 207 | return $count; |
208 | 208 | } |
209 | 209 | |
210 | + /** |
|
211 | + * @param integer $expected |
|
212 | + */ |
|
210 | 213 | protected static function getWaitingJobCount($expected) |
211 | 214 | { |
212 | 215 | $count = self::$jobManager->getWaitingJobCount(); |
@@ -252,6 +252,9 @@ |
||
252 | 252 | self::$jobManager->saveHistory($jobInQueue); |
253 | 253 | } |
254 | 254 | |
255 | + /** |
|
256 | + * @param \PhpAmqpLib\Channel\AMQPChannel $channel |
|
257 | + */ |
|
255 | 258 | protected static function drainQueue($channel) |
256 | 259 | { |
257 | 260 | $drained = 0; |