diff options
author | franck cuny <franck@lumberjaph.net> | 2010-11-26 15:37:56 +0100 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-11-26 15:37:56 +0100 |
commit | 54bd5f0bd1186b63cd62be7e1ef0ccd357cdbc88 (patch) | |
tree | 072d1eff75989082e2b9169488fccd76f088f633 /lib/presque | |
parent | add new middleware for clientid (diff) | |
download | presque-worker-54bd5f0bd1186b63cd62be7e1ef0ccd357cdbc88.tar.gz |
switch from net::http::api to net::http::spore
Diffstat (limited to 'lib/presque')
-rw-r--r-- | lib/presque/worker.pm | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/presque/worker.pm b/lib/presque/worker.pm index c7b6f01..b18b30e 100644 --- a/lib/presque/worker.pm +++ b/lib/presque/worker.pm @@ -7,7 +7,7 @@ use JSON; use Try::Tiny; use Moose::Role; -use Net::Presque; +use Net::HTTP::Spore; requires 'work'; @@ -68,10 +68,10 @@ has rest_client => ( default => sub { my $self = shift; my $client = - Net::HTTP::Spore->new( $self->spore_description, + Net::HTTP::Spore->new_from_spec( $self->spore_description, base_url => $self->context->{presque}->{url} ); $client->enable('Format::JSON'); - $client->enable( '+presque::worker::middleware::clientid', + $client->enable( '+presque::worker::Middleware::ClientID', worker_id => $self->worker_id ); $client; }, @@ -101,9 +101,9 @@ sub start { ); } catch { - $self->logger->error($_) if $_->http_error->code != 404; + $self->logger->error($_) if $_->status != 404; }; - $job ? $self->work($job) : $self->idle(); + $job ? $self->work($job->body) : $self->idle(); } } |