diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-06-28 10:22:01 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-06-28 10:22:01 +0200 |
| commit | 9360a3fc0b6996170ebde907a63f2ed60bd610f3 (patch) | |
| tree | 997be5961dd4e04abeff91483f357231c987b297 | |
| parent | fix key name (diff) | |
| download | presque-worker-9360a3fc0b6996170ebde907a63f2ed60bd610f3.tar.gz | |
missing queue_name
| -rw-r--r-- | lib/presque/worker/Role/Management.pm | 15 |
1 files changed, 12 insertions, 3 deletions
diff --git a/lib/presque/worker/Role/Management.pm b/lib/presque/worker/Role/Management.pm index c2a13fd..857da91 100644 --- a/lib/presque/worker/Role/Management.pm +++ b/lib/presque/worker/Role/Management.pm @@ -16,15 +16,24 @@ before start => sub { after start => sub { my $self = shift; - $self->unregister_worker(worker_id => $self->worker_id); + $self->register_worker( + queue_name => $self->queue_name, + worker_id => $self->worker_id + ); }; after _graceful_shutdown => sub { my $self = shift; - $self->unregister_worker(worker_id => $self->worker_id); + $self->unregister_worker( + queue_name => $self->queue_name, + worker_id => $self->worker_id + ); }; after _shutdown => sub { my $self = shift; - $self->unregister_worker(worker_id => $self->worker_id); + $self->unregister_worker( + queue_name => $self->queue_name, + worker_id => $self->worker_id + ); }; sub _shutdown { |