diff options
| author | franck cuny <franck@lumberjaph.net> | 2010-07-05 11:42:11 +0200 |
|---|---|---|
| committer | franck cuny <franck@lumberjaph.net> | 2010-07-05 11:42:11 +0200 |
| commit | 1d1c89f8b40cfa7c986ffea739464870b6b56efa (patch) | |
| tree | 1a51e04b1de3faf2c574281d07814712a038e189 /lib | |
| parent | don't log when no job is availabe (diff) | |
| download | presque-worker-1d1c89f8b40cfa7c986ffea739464870b6b56efa.tar.gz | |
remove worker's id from reg/unreg methods
Diffstat (limited to 'lib')
| -rw-r--r-- | lib/presque/worker.pm | 8 | ||||
| -rw-r--r-- | lib/presque/worker/Role/Management.pm | 3 |
2 files changed, 5 insertions, 6 deletions
diff --git a/lib/presque/worker.pm b/lib/presque/worker.pm index 89ecb83..12744bd 100644 --- a/lib/presque/worker.pm +++ b/lib/presque/worker.pm @@ -64,9 +64,11 @@ has rest_client => ( isa => 'Net::Presque', lazy => 1, default => sub { - my $self = shift; - my $client = - Net::Presque->new(api_base_url => $self->context->{presque}->{url}); + my $self = shift; + my $client = Net::Presque->new( + api_base_url => $self->context->{presque}->{url}, + worker_id => $self->worker_id + ); $client; }, handles => { diff --git a/lib/presque/worker/Role/Management.pm b/lib/presque/worker/Role/Management.pm index d168311..2b02c57 100644 --- a/lib/presque/worker/Role/Management.pm +++ b/lib/presque/worker/Role/Management.pm @@ -18,21 +18,18 @@ after start => sub { my $self = shift; $self->unregister_worker( queue_name => $self->queue_name, - worker_id => $self->worker_id ); }; after _graceful_shutdown => sub { my $self = shift; $self->unregister_worker( queue_name => $self->queue_name, - worker_id => $self->worker_id ); }; after _shutdown => sub { my $self = shift; $self->unregister_worker( queue_name => $self->queue_name, - worker_id => $self->worker_id ); }; |