| @@ -43,6 +43,9 @@ discard block | ||
| 43 | 43 | return array( 'scheduled' => Actions::do_full_sync( $modules ) ); | 
| 44 | 44 | } | 
| 45 | 45 | |
| 46 | + /** | |
| 47 | + * @return string | |
| 48 | + */ | |
| 46 | 49 |  	protected function validate_queue( $query ) { | 
| 47 | 50 |  		if ( ! isset( $query ) ) { | 
| 48 | 51 | return new WP_Error( 'invalid_queue', 'Queue name is required', 400 ); | 
| @@ -233,6 +236,9 @@ discard block | ||
| 233 | 236 | ); | 
| 234 | 237 | } | 
| 235 | 238 | |
| 239 | + /** | |
| 240 | + * @param Queue $queue | |
| 241 | + */ | |
| 236 | 242 |  	protected function get_buffer( $queue, $number_of_items ) { | 
| 237 | 243 | $start = time(); | 
| 238 | 244 | $max_duration = 5; // this will try to get the buffer |