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