summaryrefslogtreecommitdiff
path: root/lib/presque/worker.pm
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--lib/presque/worker.pm8
1 files changed, 5 insertions, 3 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 => {