Merge pull request #364 from thesmith/master

Add 'del' to ShardedJedisPipeline
redis · Nov 2, 2012 · 2058231 · 2058231
2 parents bdc517d + 909be71
commit 2058231
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java b/src/main/java/redis/clients/jedis/ShardedJedisPipeline.java
@@ -39,6 +39,13 @@ public Response<String> get(String key) {
         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
@@ -74,6 +74,8 @@ public void pipelineResponse() {
 
         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 void pipelineResponse() {
         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());