fix queue_name

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