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