@@ -180,6 +180,9 @@ |
||
| 180 | 180 | ); |
| 181 | 181 | } |
| 182 | 182 | |
| 183 | + /** |
|
| 184 | + * @param \PhpAmqpLib\Channel\AMQPChannel $channel |
|
| 185 | + */ |
|
| 183 | 186 | protected static function drainQueue($channel) |
| 184 | 187 | { |
| 185 | 188 | $drained = 0; |