diff --git a/src/main/java/redis/clients/jedis/BinaryJedis.java b/src/main/java/redis/clients/jedis/BinaryJedis.java index cea0874..26fc4a1 100644 --- a/src/main/java/redis/clients/jedis/BinaryJedis.java +++ b/src/main/java/redis/clients/jedis/BinaryJedis.java @@ -1661,8 +1661,8 @@ public class BinaryJedis implements BinaryJedisCommands { client.disconnect(); } - public String watch(final byte[] key) { - client.watch(key); + public String watch(final byte[]... keys) { + client.watch(keys); return client.getStatusCodeReply(); } diff --git a/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java b/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java index af31b64..dc38d7d 100644 --- a/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java +++ b/src/test/java/redis/clients/jedis/tests/commands/TransactionCommandsTest.java @@ -122,7 +122,7 @@ public class TransactionCommandsTest extends JedisCommandTestBase { assertEquals("bar", jedis.get("mykey")); // Binary - jedis.watch(bmykey); + jedis.watch(bmykey, "foobar".getBytes()); t = jedis.multi(); nj.connect();