diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-07-08 09:56:53 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-07-08 09:56:53 +0200 |
| commit | 92fab8de2c742a84ba850506e57555b6687f888d (patch) | |
| tree | 63ef7ad6b5dd84330a3bd08e6dadf753b3588403 | |
| parent | don't look for job in delay queues (diff) | |
| download | presque-92fab8de2c742a84ba850506e57555b6687f888d.tar.gz | |
fix missing method
| -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 ); } |