From 909be715bcdbdaf846a990c0779f74e829dcf672 Mon Sep 17 00:00:00 2001
From: Ben Smith <ben@thesmith.co.uk>
Date: Sun, 21 Oct 2012 17:17:26 +0100
Subject: [PATCH] adding del to sharded jedis pipeline

---
 .../java/redis/clients/jedis/ShardedJedisPipeline.java     | 7 +++++++
 .../clients/jedis/tests/ShardedJedisPipelineTest.java      | 4 ++++
 2 files changed, 11 insertions(+)

diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
index f58e5a7..af416c0 100644
--- a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
+++ b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
@@ -39,6 +39,13 @@ public class ShardedJedisPipeline extends Queable {
         return getResponse(BuilderFactory.STRING);
     }
 
+    public Response<Long> del(String key) {
+        Client c = getClient(key);
+        c.del(key);
+        results.add(new FutureResult(c));
+        return getResponse(BuilderFactory.LONG);
+    }
+
     public Response<Boolean> exists(String key) {
         Client c = getClient(key);
         c.exists(key);
diff --git a/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java b/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java
index 05c5df4..7574f08 100644
--- a/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java
+++ b/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java
@@ -74,6 +74,8 @@ public class ShardedJedisPipelineTest {
 
         ShardedJedisPipeline p = jedis.pipelined();
         Response<String> string = p.get("string");
+        Response<Long> del = p.del("string");
+        Response<String> emptyString = p.get("string");
         Response<String> list = p.lpop("list");
         Response<String> hash = p.hget("hash", "foo");
         Response<Set<String>> zset = p.zrange("zset", 0, -1);
@@ -91,6 +93,8 @@ public class ShardedJedisPipelineTest {
         p.sync();
 
         assertEquals("foo", string.get());
+        assertEquals(Long.valueOf(1), del.get());
+        assertNull(emptyString.get());
         assertEquals("foo", list.get());
         assertEquals("bar", hash.get());
         assertEquals("foo", zset.get().iterator().next());