From 51de5f72abacbe544429fa24139ddfe8f57da71f Mon Sep 17 00:00:00 2001
From: Steve Parrington <steven.parrington@bt.com>
Date: Wed, 21 May 2014 16:09:47 +0100
Subject: [PATCH 1/2] Added Set NXXX and EXPX options for JedisCluster and
 ShardedJedis

---
 src/main/java/redis/clients/jedis/JedisCluster.java  | 12 ++++++++++++
 src/main/java/redis/clients/jedis/JedisCommands.java |  3 +++
 src/main/java/redis/clients/jedis/ShardedJedis.java  |  5 +++++
 3 files changed, 20 insertions(+)

diff --git a/src/main/java/redis/clients/jedis/JedisCluster.java b/src/main/java/redis/clients/jedis/JedisCluster.java
index 121bde8..def62ae 100644
--- a/src/main/java/redis/clients/jedis/JedisCluster.java
+++ b/src/main/java/redis/clients/jedis/JedisCluster.java
@@ -44,6 +44,18 @@ public class JedisCluster implements JedisCommands, BasicCommands {
 	}.run(key);
     }
 
+    @Override
+    public String set(final String key, final String value, final String nxxx,
+                      final String expx, final long time) {
+        return new JedisClusterCommand<String>(connectionHandler, timeout,
+                maxRedirections) {
+            @Override
+            public String execute(Jedis connection) {
+                return connection.set(key, value, nxxx, expx, time);
+            }
+        }.run(key);
+    }
+
     @Override
     public String get(final String key) {
 	return new JedisClusterCommand<String>(connectionHandler, timeout,
diff --git a/src/main/java/redis/clients/jedis/JedisCommands.java b/src/main/java/redis/clients/jedis/JedisCommands.java
index 5952bdb..7d1984d 100644
--- a/src/main/java/redis/clients/jedis/JedisCommands.java
+++ b/src/main/java/redis/clients/jedis/JedisCommands.java
@@ -10,6 +10,9 @@ import java.util.Set;
 public interface JedisCommands {
     String set(String key, String value);
 
+    String set(String key, String value, String nxxx,
+                    String expx, long time);
+
     String get(String key);
 
     Boolean exists(String key);
diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java
index 7235cfe..e485c6c 100644
--- a/src/main/java/redis/clients/jedis/ShardedJedis.java
+++ b/src/main/java/redis/clients/jedis/ShardedJedis.java
@@ -32,6 +32,11 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands {
 	return j.set(key, value);
     }
 
+    public String set(String key, String value, String nxxx,
+               String expx, long time) {
+        Jedis j = getShard(key);
+        return j.set(key, value, nxxx, expx, time);
+    }
     public String get(String key) {
 	Jedis j = getShard(key);
 	return j.get(key);

From 742e83b1e030706a56c02f61aaa11d65a91d7bdc Mon Sep 17 00:00:00 2001
From: Steve Parrington <steven.parrington@bt.com>
Date: Thu, 22 May 2014 11:29:55 +0100
Subject: [PATCH 2/2] Added override annotation to ShardedJedis.set()

---
 src/main/java/redis/clients/jedis/ShardedJedis.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/src/main/java/redis/clients/jedis/ShardedJedis.java b/src/main/java/redis/clients/jedis/ShardedJedis.java
index e485c6c..a44d330 100644
--- a/src/main/java/redis/clients/jedis/ShardedJedis.java
+++ b/src/main/java/redis/clients/jedis/ShardedJedis.java
@@ -32,11 +32,13 @@ public class ShardedJedis extends BinaryShardedJedis implements JedisCommands {
 	return j.set(key, value);
     }
 
+    @Override
     public String set(String key, String value, String nxxx,
                String expx, long time) {
         Jedis j = getShard(key);
         return j.set(key, value, nxxx, expx, time);
     }
+
     public String get(String key) {
 	Jedis j = getShard(key);
 	return j.get(key);