From 2f9564e1d331a2cfad400eea17fdf4058e98dd48 Mon Sep 17 00:00:00 2001 From: Marcos Nils Date: Tue, 14 Jan 2014 21:20:33 -0300 Subject: [PATCH] Variable refactor in JedisClusterTest --- .../redis/clients/jedis/tests/JedisClusterTest.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/src/test/java/redis/clients/jedis/tests/JedisClusterTest.java b/src/test/java/redis/clients/jedis/tests/JedisClusterTest.java index d612b5e..08ce912 100644 --- a/src/test/java/redis/clients/jedis/tests/JedisClusterTest.java +++ b/src/test/java/redis/clients/jedis/tests/JedisClusterTest.java @@ -129,10 +129,11 @@ public class JedisClusterTest extends Assert { Set jedisClusterNode = new HashSet(); jedisClusterNode.add(new HostAndPort("127.0.0.1", 7379)); JedisCluster jc = new JedisCluster(jedisClusterNode); - node2.clusterDelSlots(JedisClusterCRC16.getSlot("51")); + int slot51 = JedisClusterCRC16.getSlot("51"); + node2.clusterDelSlots(slot51); //TODO: We shouldn't need to issue DELSLOTS in node3, but due to redis-cluster bug we need to. - node3.clusterDelSlots(JedisClusterCRC16.getSlot("51")); - node3.clusterAddSlots(JedisClusterCRC16.getSlot("51")); + node3.clusterDelSlots(slot51); + node3.clusterAddSlots(slot51); waitForClusterReady(); jc.set("51", "foo"); assertEquals("foo", jc.get("51")); @@ -143,8 +144,9 @@ public class JedisClusterTest extends Assert { Set jedisClusterNode = new HashSet(); jedisClusterNode.add(new HostAndPort("127.0.0.1", 7379)); JedisCluster jc = new JedisCluster(jedisClusterNode); - node3.clusterSetSlotImporting(JedisClusterCRC16.getSlot("51"), getNodeId(node2.clusterNodes())); - node2.clusterSetSlotMigrating(JedisClusterCRC16.getSlot("51"), getNodeId(node3.clusterNodes())); + int slot51 = JedisClusterCRC16.getSlot("51"); + node3.clusterSetSlotImporting(slot51, getNodeId(node2.clusterNodes())); + node2.clusterSetSlotMigrating(slot51, getNodeId(node3.clusterNodes())); jc.set("51", "foo"); assertEquals("foo", jc.get("51")); }