From 18c4a987d5e5d515576176bdc1ccbaaf1944c73e Mon Sep 17 00:00:00 2001 From: Lars Strojny Date: Tue, 1 Jul 2014 15:10:07 +0200 Subject: [PATCH] Completing interface --- .../java/redis/clients/jedis/BinaryJedisCommands.java | 2 ++ .../java/redis/clients/jedis/BinaryShardedJedis.java | 6 ++++++ src/main/java/redis/clients/jedis/JedisCluster.java | 11 +++++++++++ src/main/java/redis/clients/jedis/JedisCommands.java | 2 ++ src/main/java/redis/clients/jedis/ShardedJedis.java | 6 ++++++ 5 files changed, 27 insertions(+) diff --git a/src/main/java/redis/clients/jedis/BinaryJedisCommands.java b/src/main/java/redis/clients/jedis/BinaryJedisCommands.java index ada68c2..ebd59fd 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedisCommands.java +++ b/src/main/java/redis/clients/jedis/BinaryJedisCommands.java @@ -115,6 +115,8 @@ public interface BinaryJedisCommands { byte[] srandmember(byte[] key); + List srandmember(final byte[] key, final int count); + Long strlen(byte[] key); Long zadd(byte[] key, double score, byte[] member); diff --git a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java index 77695e7..7fbcb94 100644 --- a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java @@ -300,6 +300,12 @@ public class BinaryShardedJedis extends Sharded return j.srandmember(key); } + @Override + public List srandmember(byte[] key, int count) { + Jedis j = getShard(key); + return j.srandmember(key, count); + } + public Long zadd(byte[] key, double score, byte[] member) { Jedis j = getShard(key); return j.zadd(key, score, member); diff --git a/src/main/java/redis/clients/jedis/JedisCluster.java b/src/main/java/redis/clients/jedis/JedisCluster.java index f6cb6fd..029ea55 100644 --- a/src/main/java/redis/clients/jedis/JedisCluster.java +++ b/src/main/java/redis/clients/jedis/JedisCluster.java @@ -623,6 +623,17 @@ public class JedisCluster implements JedisCommands, BasicCommands { }.run(key); } + @Override + public List srandmember(final String key, final int count) { + return new JedisClusterCommand>(connectionHandler, timeout, + maxRedirections) { + @Override + public List execute(Jedis connection) { + return connection.srandmember(key, count); + } + }.run(key); + } + @Override public Long strlen(final String key) { return new JedisClusterCommand(connectionHandler, timeout, diff --git a/src/main/java/redis/clients/jedis/JedisCommands.java b/src/main/java/redis/clients/jedis/JedisCommands.java index d89f508..6d794cb 100644 --- a/src/main/java/redis/clients/jedis/JedisCommands.java +++ b/src/main/java/redis/clients/jedis/JedisCommands.java @@ -113,6 +113,8 @@ public interface JedisCommands { String srandmember(String key); + List srandmember(String key, int count); + Long strlen(String key); Long zadd(String key, double score, String member); diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java index 9691448..35ac3e5 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedis.java +++ b/src/main/java/redis/clients/jedis/ShardedJedis.java @@ -346,6 +346,12 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands, return j.srandmember(key); } + @Override + public List srandmember(String key, int count) { + Jedis j = getShard(key); + return j.srandmember(key, count); + } + public Long zadd(String key, double score, String member) { Jedis j = getShard(key); return j.zadd(key, score, member);