diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-28 10:25:23 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-28 10:25:23 +0200 |
| commit | 8f8ce00fe70245fd964071b199f6b68e7fa5321c (patch) | |
| tree | 08216a4c014fe503fd9c3c7b45678ace4ecb9b26 /lib/presque/worker/Role | |
| parent | missing queue_name (diff) | |
| download | presque-worker-8f8ce00fe70245fd964071b199f6b68e7fa5321c.tar.gz | |
missing queue_name
Diffstat (limited to 'lib/presque/worker/Role')
| -rw-r--r-- | lib/presque/worker/Role/Management.pm | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/lib/presque/worker/Role/Management.pm b/lib/presque/worker/Role/Management.pm index 857da91..e24c302 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(worker_id => $self->worker_id); + $self->register_worker(queue_name => worker_id => $self->worker_id); $SIG{INT} = sub { $self->_shutdown }; $SIG{TERM} = sub { $self->_shutdown }; $SIG{QUIT} = sub { $self->_graceful_shutdown }; @@ -16,7 +16,7 @@ before start => sub { after start => sub { my $self = shift; - $self->register_worker( + $self->unregister_worker( queue_name => $self->queue_name, worker_id => $self->worker_id ); |