diff --git a/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java b/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java index 22f1d10..395f2ec 100644 --- a/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java +++ b/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java @@ -32,13 +32,13 @@ public class ShardedJedisPipelineTest { jedis.flushAll(); jedis.disconnect(); + JedisShardInfo shardInfo1 = new JedisShardInfo(redis1.host, redis1.port); + JedisShardInfo shardInfo2 = new JedisShardInfo(redis2.host, redis2.port); + shardInfo1.setPassword("foobared"); + shardInfo2.setPassword("foobared"); List shards = new ArrayList(); - JedisShardInfo si1 = new JedisShardInfo(redis1.host, redis1.port); - si1.setPassword("foobared"); - shards.add(si1); - JedisShardInfo si2 = new JedisShardInfo(redis2.host, redis2.port); - si2.setPassword("foobared"); - shards.add(si2); + shards.add(shardInfo1); + shards.add(shardInfo2); this.jedis = new ShardedJedis(shards); } @@ -53,7 +53,6 @@ public class ShardedJedisPipelineTest { assertEquals(2, results.size()); assertEquals("OK", results.get(0)); assertEquals("bar", results.get(1)); - } @Test diff --git a/src/test/java/redis/clients/jedis/tests/commands/ControlCommandsTest.java b/src/test/java/redis/clients/jedis/tests/commands/ControlCommandsTest.java index c6b6698..7e59335 100644 --- a/src/test/java/redis/clients/jedis/tests/commands/ControlCommandsTest.java +++ b/src/test/java/redis/clients/jedis/tests/commands/ControlCommandsTest.java @@ -29,8 +29,13 @@ public class ControlCommandsTest extends JedisCommandTestBase { @Test public void bgrewriteaof() { + String scheduled = "Background append only file rewriting scheduled"; + String started = "Background append only file rewriting started"; + String status = jedis.bgrewriteaof(); - assertEquals("Background append only file rewriting started", status); + + boolean ok = status.equals(scheduled) || status.equals(started); + assertTrue(ok); } @Test