From 1ae712311b2dbc48a8af751b1f81f9fb3203ed25 Mon Sep 17 00:00:00 2001
From: Robin Edwards <robin.ge@gmail.com>
Date: Tue, 5 Oct 2010 14:25:13 +0100
Subject: requests and responses now stored for debugging

---
 lib/Net/Riak/MapReduce.pm | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

(limited to 'lib/Net/Riak/MapReduce.pm')

diff --git a/lib/Net/Riak/MapReduce.pm b/lib/Net/Riak/MapReduce.pm
index f0dffd5..03a3dd3 100644
--- a/lib/Net/Riak/MapReduce.pm
+++ b/lib/Net/Riak/MapReduce.pm
@@ -159,17 +159,18 @@ sub run {
 
     my $content = JSON::encode_json($job);
 
-    my $request =
-      $self->client->request('POST', [$self->client->mapred_prefix]);
+    my $request = $self->client->new_request(
+        'POST', [$self->client->mapred_prefix]
+    );
     $request->content($content);
 
-    my $response = $self->client->useragent->request($request);
+    my $response = $self->client->send_request($request);
 
     unless ($response->is_success) {
-        die $response->content;
+        die "MapReduce query failed: ".$response->status_line;
     }
 
-    my $result   = JSON::decode_json($response->content);
+    my $result = JSON::decode_json($response->content);
 
     if ( $timeout && ( $ua_timeout != $self->client->useragent->timeout() ) ) {
         $self->client->useragent->timeout($ua_timeout);
-- 
cgit v1.2.3