From d526a32b12403609b9c7c68f17a8cfbc00c48f40 Mon Sep 17 00:00:00 2001
From: ivowiblo <ivowiblo@gmail.com>
Date: Sun, 29 Apr 2012 02:55:22 -0400
Subject: [PATCH] Pipeline.exec() now returns a response

---
 src/main/java/redis/clients/jedis/Pipeline.java             | 6 +++---
 src/test/java/redis/clients/jedis/tests/PipeliningTest.java | 6 +++++-
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/main/java/redis/clients/jedis/Pipeline.java b/src/main/java/redis/clients/jedis/Pipeline.java
index 3f417a6..1e04deb 100644
--- a/src/main/java/redis/clients/jedis/Pipeline.java
+++ b/src/main/java/redis/clients/jedis/Pipeline.java
@@ -1218,10 +1218,11 @@ public class Pipeline extends Queable {
         return getResponse(BuilderFactory.STRING);
     }
 
-    public void exec() {
+    public Response<List<Object>> exec() {
         client.exec();
-        super.getResponse(currentMulti);
+        Response<List<Object>> response = super.getResponse(currentMulti);
         currentMulti = null;
+        return response;
     }
 
     public void multi() {
@@ -1279,5 +1280,4 @@ public class Pipeline extends Queable {
     	client.select(index);
     	return getResponse(BuilderFactory.STRING);
     }    
-   
 }
\ No newline at end of file
diff --git a/src/test/java/redis/clients/jedis/tests/PipeliningTest.java b/src/test/java/redis/clients/jedis/tests/PipeliningTest.java
index 93afb10..568a2cd 100644
--- a/src/test/java/redis/clients/jedis/tests/PipeliningTest.java
+++ b/src/test/java/redis/clients/jedis/tests/PipeliningTest.java
@@ -171,7 +171,7 @@ public class PipeliningTest extends Assert {
         p.multi();
         Response<Long> r1 = p.hincrBy("a", "f1", -1);
         Response<Long> r2 = p.hincrBy("a", "f1", -2);
-        p.exec();
+        Response<List<Object>> r3 = p.exec();
         List<Object> result = p.syncAndReturnAll();
         
         assertEquals(new Long(-1), r1.get());
@@ -188,5 +188,9 @@ public class PipeliningTest extends Assert {
 		List<Object> multiResult = (List<Object>) result.get(3);
         assertEquals(new Long(-1), multiResult.get(0));
         assertEquals(new Long(-3), multiResult.get(1));
+        
+        assertEquals(new Long(-1), r3.get().get(0));
+        assertEquals(new Long(-3), r3.get().get(1));
+        
     }
 }