DATAREDIS-842 - Consider database index when connecting to Redis using Redis Sentinel.

Original pull request: #345.
This commit is contained in:
Ruben Cervilla
2018-06-06 11:06:18 +02:00
committed by Mark Paluch
parent 7bfafa3ed5
commit e61beb441f
2 changed files with 20 additions and 0 deletions

View File

@@ -609,4 +609,23 @@ public class LettuceConnectionFactoryUnitTests {
verify(clientMock).connect(ArgumentMatchers.any(RedisCodec.class));
}
@Test // DATAREDIS-842
public void databaseShouldBeSetCorrectlyOnSentinelClient() {
RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration("mymaster", Collections.singleton("host:1234"));
redisSentinelConfiguration.setDatabase(1);
LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory(redisSentinelConfiguration);
connectionFactory.setClientResources(getSharedClientResources());
connectionFactory.setPassword("o_O");
connectionFactory.afterPropertiesSet();
ConnectionFactoryTracker.add(connectionFactory);
AbstractRedisClient client = (AbstractRedisClient) getField(connectionFactory, "client");
assertThat(client, instanceOf(RedisClient.class));
RedisURI redisUri = (RedisURI) getField(client, "redisURI");
assertThat(redisUri.getDatabase(), is(equalTo(1)));
}
}