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