diff --git a/src/main/java/redis/clients/jedis/BinaryJedisCommands.java b/src/main/java/redis/clients/jedis/BinaryJedisCommands.java index 922c00d..77189f7 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedisCommands.java +++ b/src/main/java/redis/clients/jedis/BinaryJedisCommands.java @@ -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); } diff --git a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java index 87eb1fc..c15efb0 100644 --- a/src/main/java/redis/clients/jedis/BinaryShardedJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryShardedJedis.java @@ -190,6 +190,17 @@ public class BinaryShardedJedis extends Sharded 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); diff --git a/src/main/java/redis/clients/jedis/JedisCommands.java b/src/main/java/redis/clients/jedis/JedisCommands.java index c6ddf1e..3cb90e3 100644 --- a/src/main/java/redis/clients/jedis/JedisCommands.java +++ b/src/main/java/redis/clients/jedis/JedisCommands.java @@ -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); } diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java index 507868c..fd66fef 100644 --- a/src/main/java/redis/clients/jedis/ShardedJedis.java +++ b/src/main/java/redis/clients/jedis/ShardedJedis.java @@ -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);