summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorfranck cuny <franck@lumberjaph.net>2010-11-26 15:37:56 +0100
committerfranck cuny <franck@lumberjaph.net>2010-11-26 15:37:56 +0100
commit54bd5f0bd1186b63cd62be7e1ef0ccd357cdbc88 (patch)
tree072d1eff75989082e2b9169488fccd76f088f633
parentadd new middleware for clientid (diff)
downloadpresque-worker-54bd5f0bd1186b63cd62be7e1ef0ccd357cdbc88.tar.gz
switch from net::http::api to net::http::spore
-rw-r--r--lib/presque/worker.pm10
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();
}
}