diff --git a/src/test/java/redis/clients/jedis/tests/SharedJedisPipelineTest.java b/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java similarity index 90% rename from src/test/java/redis/clients/jedis/tests/SharedJedisPipelineTest.java rename to src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java index 7ca2a52..22f1d10 100644 --- a/src/test/java/redis/clients/jedis/tests/SharedJedisPipelineTest.java +++ b/src/test/java/redis/clients/jedis/tests/ShardedJedisPipelineTest.java @@ -13,7 +13,7 @@ import static junit.framework.Assert.assertNull; import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotNull; -public class SharedJedisPipelineTest { +public class ShardedJedisPipelineTest { private static HostAndPortUtil.HostAndPort redis1 = HostAndPortUtil.getRedisServers() .get(0); private static HostAndPortUtil.HostAndPort redis2 = HostAndPortUtil.getRedisServers() @@ -24,18 +24,25 @@ public class SharedJedisPipelineTest { @Before public void setUp() throws Exception { Jedis jedis = new Jedis(redis1.host, redis1.port); + jedis.auth("foobared"); jedis.flushAll(); jedis.disconnect(); jedis = new Jedis(redis2.host, redis2.port); + jedis.auth("foobared"); jedis.flushAll(); jedis.disconnect(); List shards = new ArrayList(); - shards.add(new JedisShardInfo(redis1.host, redis1.port)); - shards.add(new JedisShardInfo(redis2.host, redis2.port)); + 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); this.jedis = new ShardedJedis(shards); } + @Test public void pipeline() throws UnsupportedEncodingException { ShardedJedisPipeline p = jedis.pipelined();