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/Management.pm | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) (limited to 'lib/presque/worker/Role/Management.pm') 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 }; -- cgit v1.2.3