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 del(String key) { + Client c = getClient(key); + c.del(key); + results.add(new FutureResult(c)); + return getResponse(BuilderFactory.LONG); + } + public Response 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 = p.get("string"); + Response del = p.del("string"); + Response emptyString = p.get("string"); Response list = p.lpop("list"); Response hash = p.hget("hash", "foo"); Response> 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());