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
                             );
                         }