diff options
-rw-r--r-- | lib/presque/worker/Role/Job.pm | 2 | ||||
-rw-r--r-- | lib/presque/worker/Role/Logger.pm | 2 | ||||
-rw-r--r-- | lib/presque/worker/Role/Management.pm | 2 |
3 files changed, 3 insertions, 3 deletions
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 diff --git a/lib/presque/worker/Role/Logger.pm b/lib/presque/worker/Role/Logger.pm index f9c0702..ff0090e 100644 --- a/lib/presque/worker/Role/Logger.pm +++ b/lib/presque/worker/Role/Logger.pm @@ -16,7 +16,7 @@ has logger => ( foreach my $log_type (keys %{$log_conf}) { my $log_engine = $self->_load_log_engine($log_type); my $_logger = - $log_engine->new(%{$self->context->{log}->{$log_type}}); + $log_engine->new(%{$self->context->{logger}->{$log_type}}); $logger->add($_logger); } } diff --git a/lib/presque/worker/Role/Management.pm b/lib/presque/worker/Role/Management.pm index e24c302..d168311 100644 --- a/lib/presque/worker/Role/Management.pm +++ b/lib/presque/worker/Role/Management.pm @@ -6,7 +6,7 @@ has shut_down => (is => 'rw', isa => 'Bool', default => 0,); before start => sub { my $self = shift; - $self->register_worker(queue_name => worker_id => $self->worker_id); + $self->register_worker(queue_name => $self->queue_name, worker_id => $self->worker_id); $SIG{INT} = sub { $self->_shutdown }; $SIG{TERM} = sub { $self->_shutdown }; $SIG{QUIT} = sub { $self->_graceful_shutdown }; |