From 13f0c32f7cbccc12cd00eb42dd1551d001eebcd5 Mon Sep 17 00:00:00 2001 From: Jungtaek Lim Date: Wed, 5 Feb 2014 00:41:34 +0900 Subject: [PATCH] Add unit test for "sentinel set quorum" introduced by Redis 2.8.5 --- .../java/redis/clients/jedis/tests/JedisSentinelTest.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java b/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java index 833151e..da0d5af 100644 --- a/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java +++ b/src/test/java/redis/clients/jedis/tests/JedisSentinelTest.java @@ -134,6 +134,7 @@ public class JedisSentinelTest extends JedisTestBase { Map parameterMap = new HashMap(); parameterMap.put("down-after-milliseconds", String.valueOf(1234)); parameterMap.put("parallel-syncs", String.valueOf(3)); + parameterMap.put("quorum", String.valueOf(2)); j.sentinelSet(MASTER_NAME, parameterMap); List> masters = j.sentinelMasters(); @@ -141,8 +142,12 @@ public class JedisSentinelTest extends JedisTestBase { if (master.get("name").equals(MASTER_NAME)) { assertEquals(1234, Integer.parseInt(master.get("down-after-milliseconds"))); assertEquals(3, Integer.parseInt(master.get("parallel-syncs"))); + assertEquals(2, Integer.parseInt(master.get("quorum"))); } } + + parameterMap.put("quorum", String.valueOf(1)); + j.sentinelSet(MASTER_NAME, parameterMap); } private void ensureMonitored(HostAndPort sentinel, String masterName, String ip, int port, int quorum) {