diff options
Diffstat (limited to '')
| -rw-r--r-- | lib/presque/RestQueueBatchHandler.pm | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/lib/presque/RestQueueBatchHandler.pm b/lib/presque/RestQueueBatchHandler.pm index abf36c5..2b81f95 100644 --- a/lib/presque/RestQueueBatchHandler.pm +++ b/lib/presque/RestQueueBatchHandler.pm @@ -22,6 +22,12 @@ sub _fetch_job { my $lkey = $self->_queue($queue_name); + $self->_get_jobs_from_queue($queue_name, $lkey, $pos, $batch_size, $jobs, $keys); +} + +sub _get_jobs_from_queue { + my ($self, $queue_name, $lkey, $pos, $batch_size, $jobs, $keys) = @_; + $self->application->redis->lpop( $lkey, sub { @@ -39,7 +45,7 @@ sub _fetch_job { } else { $self->_get_jobs_from_queue( - $queue_name, $pos, $batch_size, + $queue_name, $lkey, $pos, $batch_size, $jobs, $keys ); } |