From 0340fddb3ae750c9deb119c7450618609fa0536a Mon Sep 17 00:00:00 2001 From: guycoleman Date: Mon, 3 Dec 2012 15:36:30 +0000 Subject: [PATCH] Add persist to ShardedJedis --- .../redis/clients/jedis/BinaryShardedJedis.java | 14 +++++++++----- .../java/redis/clients/jedis/ShardedJedis.java | 11 ++++++++--- 2 files changed, 17 insertions(+), 8 deletions(-) diff --git a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java index 23fd6d6..a6bed45 100644 --- a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java @@ -1,5 +1,9 @@ package redis.clients.jedis; +import redis.clients.jedis.BinaryClient.LIST_POSITION; +import redis.clients.util.Hashing; +import redis.clients.util.Sharded; + import java.io.IOException; import java.util.Collection; import java.util.List; @@ -7,10 +11,6 @@ import java.util.Map; import java.util.Set; import java.util.regex.Pattern; -import redis.clients.jedis.BinaryClient.LIST_POSITION; -import redis.clients.util.Hashing; -import redis.clients.util.Sharded; - public class BinaryShardedJedis extends Sharded implements BinaryJedisCommands { public BinaryShardedJedis(List shards) { @@ -199,7 +199,11 @@ public class BinaryShardedJedis extends Sharded Jedis j = getShard(key); return j.lpushx(key, string); } - + + public Long persist(final byte[] key) { + Jedis j = getShard(key); + return j.persist(key); + } public Long rpushx(byte[] key, byte[] string) { Jedis j = getShard(key); diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java index ea2f11e..dc82999 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedis.java +++ b/src/main/java/redis/clients/jedis/ShardedJedis.java @@ -1,13 +1,13 @@ package redis.clients.jedis; +import redis.clients.jedis.BinaryClient.LIST_POSITION; +import redis.clients.util.Hashing; + import java.util.List; import java.util.Map; import java.util.Set; import java.util.regex.Pattern; -import redis.clients.jedis.BinaryClient.LIST_POSITION; -import redis.clients.util.Hashing; - public class ShardedJedis extends BinaryShardedJedis implements JedisCommands { public ShardedJedis(List shards) { super(shards); @@ -218,6 +218,11 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands { return j.rpushx(key, string); } + public Long persist(final String key) { + Jedis j = getShard(key); + return j.persist(key); + } + public Long llen(String key) { Jedis j = getShard(key); return j.llen(key);