From e047c32a259dc61705bb29308b0a39ae742bc2b4 Mon Sep 17 00:00:00 2001 From: franck cuny Date: Mon, 28 Jun 2010 10:51:43 +0200 Subject: fix queue_name --- lib/presque/worker/Role/Job.pm | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'lib/presque/worker/Role/Job.pm') diff --git a/lib/presque/worker/Role/Job.pm b/lib/presque/worker/Role/Job.pm index 3681580..c8a0e17 100644 --- a/lib/presque/worker/Role/Job.pm +++ b/lib/presque/worker/Role/Job.pm @@ -10,7 +10,7 @@ sub _job_failure { my $retries = ($job->{retries_left} || $self->job_retries) - 1; $job->{retries_left} = $retries; try { - $self->retry_job(queue_name => '', $job) if $retries > 0; + $self->retry_job(queue_name => $self->queue_name, $job) if $retries > 0; } catch { # XXX -- cgit 1.4.1