@@ -233,6 +233,10 @@ |
||
| 233 | 233 | ); |
| 234 | 234 | } |
| 235 | 235 | |
| 236 | + /** |
|
| 237 | + * @param Queue $queue |
|
| 238 | + * @param integer $number_of_items |
|
| 239 | + */ |
|
| 236 | 240 | protected function get_buffer( $queue, $number_of_items ) { |
| 237 | 241 | $start = time(); |
| 238 | 242 | $max_duration = 5; // this will try to get the buffer |