Merge pull request #2032 from sazzad16/unwatch-multi-pipeline

Add missing UNWATCH in Transaction and Pipeline

Author: sazzad16

src/main/java/redis/clients/jedis/MultiKeyPipelineBase.java

@@ -307,6 +307,12 @@ public Response<String> watch(byte[]... keys) {
     return getResponse(BuilderFactory.STRING);
   }
 
+  @Override
+  public Response<String> unwatch() {
+    client.unwatch();
+    return getResponse(BuilderFactory.STRING);
+  }
+
   @Override
   public Response<Long> zinterstore(String dstkey, String... sets) {
     client.zinterstore(dstkey, sets);

src/main/java/redis/clients/jedis/commands/MultiKeyBinaryRedisPipeline.java

@@ -58,6 +58,8 @@ public interface MultiKeyBinaryRedisPipeline {
 
   Response<String> watch(byte[]... keys);
 
+  Response<String> unwatch();
+
   Response<Long> zinterstore(byte[] dstkey, byte[]... sets);
 
   Response<Long> zinterstore(byte[] dstkey, ZParams params, byte[]... sets);

src/main/java/redis/clients/jedis/commands/MultiKeyCommandsPipeline.java

@@ -57,6 +57,8 @@ public interface MultiKeyCommandsPipeline {
 
   Response<String> watch(String... keys);
 
+  Response<String> unwatch();
+
   Response<Long> zinterstore(String dstkey, String... sets);
 
   Response<Long> zinterstore(String dstkey, ZParams params, String... sets);

src/test/java/redis/clients/jedis/tests/PipeliningTest.java

@@ -308,6 +308,24 @@ public void multiWithSync() {
     assertEquals("world", r3.get());
   }
 
+  @Test
+  public void multiWithWatch() {
+    String key = "foo";
+    String val = "bar";
+    List<Object> expect = new ArrayList<>();
+    List<Object> expMulti = new ArrayList<>();
+
+    Pipeline pipe = jedis.pipelined();
+    pipe.set(key, val); expect.add("OK");
+    pipe.watch(key);    expect.add("OK");
+    pipe.multi();       expect.add("OK");
+    pipe.unwatch();     expect.add("QUEUED");   expMulti.add("OK");
+    pipe.get(key);      expect.add("QUEUED");   expMulti.add(val);
+    pipe.exec();        expect.add(expMulti);
+
+    assertEquals(expect, pipe.syncAndReturnAll());
+  }
+
   @Test(expected = JedisDataException.class)
   public void pipelineExecShoudThrowJedisDataExceptionWhenNotInMulti() {
     Pipeline pipeline = jedis.pipelined();