Merge branch 'Issue221' of https://github.com/ivowiblo/jedis into issue221

Conflicts:
	src/main/java/redis/clients/jedis/BinaryJedisCommands.java
This commit is contained in:
Jonathan Leibiusky
2012-05-06 19:30:37 -03:00
4 changed files with 30 additions and 1 deletions

View File

@@ -173,7 +173,7 @@ public interface BinaryJedisCommands {
Long zremrangeByScore(byte[] key, double start, double end);
Long zremrangeByScore(byte[] key, byte[] start, byte[] end);
Long linsert(byte[] key, LIST_POSITION where, byte[] pivot, byte[] value);
Long objectRefcount(byte[] key);
@@ -181,4 +181,8 @@ public interface BinaryJedisCommands {
Long objectIdletime(byte[] key);
byte[] objectEncoding(byte[] key);
Long lpushx(byte[] key, byte[] string);
Long rpushx(byte[] key, byte[] string);
}

View File

@@ -190,6 +190,17 @@ public class BinaryShardedJedis extends Sharded<Jedis, JedisShardInfo>
return j.lpush(key, strings);
}
public Long lpushx(byte[] key, byte[] string) {
Jedis j = getShard(key);
return j.lpushx(key, string);
}
public Long rpushx(byte[] key, byte[] string) {
Jedis j = getShard(key);
return j.rpushx(key, string);
}
public Long llen(byte[] key) {
Jedis j = getShard(key);
return j.llen(key);

View File

@@ -186,4 +186,8 @@ public interface JedisCommands {
Long linsert(String key, Client.LIST_POSITION where, String pivot,
String value);
Long lpushx(String key, String string);
Long rpushx(String key, String string);
}

View File

@@ -207,6 +207,16 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands {
Jedis j = getShard(key);
return j.lpush(key, strings);
}
public Long lpushx(String key, String string) {
Jedis j = getShard(key);
return j.lpushx(key, string);
}
public Long rpushx(String key, String string) {
Jedis j = getShard(key);
return j.rpushx(key, string);
}
public Long llen(String key) {
Jedis j = getShard(key);