From 92fab8de2c742a84ba850506e57555b6687f888d Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Thu, 8 Jul 2010 09:56:53 +0200
Subject: fix missing method

---
 lib/presque/RestQueueBatchHandler.pm | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

(limited to 'lib')

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