a simple worker; a role for the REST interface to presque; reg signals

to shutdown workers; log before starting a task; fork dispatcher (a la resque)

1 files changed, 8 insertions, 4 deletions

diff --git a/lib/presque/worker/Role/RESTClient.pm b/lib/presque/worker/Role/RESTClient.pm
index 0015b98..dd84fda 100644
--- a/lib/presque/worker/Role/RESTClient.pm
+++ b/lib/presque/worker/Role/RESTClient.pm
@@ -39,13 +39,14 @@ sub rest_register_worker {
 
 sub rest_unregister_worker {
     my $self = shift;
-    my $request = HTTP::Request->new(DELETE => $self->_worker_uri);
-    $request->query_path(worker_id => $self->worker_id);
+    my $uri  = $self->_worker_uri;
+    $uri->query_form(worker_id => $self->worker_id);
+    my $request = HTTP::Request->new(DELETE => $uri);
     my $res = $self->ua->request($request);
 }
 
 sub rest_fetch_job {
-    my ($self,) = @_;
+    my $self = shift;
 
     my $res = $self->ua->request(HTTP::Request->new(GET => $self->_job_uri));
     if ($res->is_success) {
@@ -57,20 +58,23 @@ sub rest_fetch_job {
             message => $res->code . ':' . $res->message
         );
     }
+    return;
 }
 
 sub rest_retry_job {
     my ($self, $job) = @_;
 
     my $request = HTTP::Request->new(PUT => $self->_job_uri);
+    $request->header('Content-Type' => 'application/json');
     $request->content(JSON::encode_json($job));
     my $res = $self->ua->request($request);
     if (!$res->is_success) {
+        use YAML::Syck; warn Dump $res;
         $self->logger->log(
             level   => 'error',
             message => 'failed to update job ('
               . $res->code . ':'
-              . $res->reason . ')',
+              . $res->message . ')',
         );
     }
 }