DATAREDIS-765 - Enable pooling when configuring Jedis to use Redis Sentinel.

pom.xml

@@ -5,7 +5,7 @@
 
 	<groupId>org.springframework.data</groupId>
 	<artifactId>spring-data-redis</artifactId>
-	<version>2.1.0.BUILD-SNAPSHOT</version>
+	<version>2.1.0.DATAREDIS-765-SNAPSHOT</version>
 
 	<name>Spring Data Redis</name>
 

src/main/java/org/springframework/data/redis/connection/jedis/JedisConnectionFactory.java

@@ -660,6 +660,12 @@ public void setTimeout(int timeout) {
 	 * @return the use of connection pooling.
 	 */
 	public boolean getUsePool() {
+
+		// Jedis Sentinel cannot operate without a pool.
+		if (isRedisSentinelAware()) {
+			return true;
+		}
+
 		return clientConfiguration.isUsePooling();
 	}
 
@@ -669,9 +675,16 @@ public boolean getUsePool() {
 	 * @param usePool the usePool to set.
 	 * @deprecated since 2.0, configure pooling usage with {@link JedisClientConfiguration}.
 	 * @throws IllegalStateException if {@link JedisClientConfiguration} is immutable.
+	 * @throws IllegalStateException if configured to use sentinel and {@code usePool} is {@literal false} as Jedis
+	 *           requires pooling for Redis sentinel use.
 	 */
 	@Deprecated
 	public void setUsePool(boolean usePool) {
+
+		if (isRedisSentinelAware() && !usePool) {
+			throw new IllegalStateException("Jedis requires pooling for Redis Sentinel use!");
+		}
+
 		getMutableConfiguration().setUsePooling(usePool);
 	}
 

src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionFactorySentinelIntegrationTests.java

@@ -15,12 +15,13 @@
  */
 package org.springframework.data.redis.connection.jedis;
 
-import static org.hamcrest.core.IsEqual.*;
+import static org.hamcrest.Matchers.*;
 import static org.junit.Assert.*;
 
 import org.junit.After;
 import org.junit.Rule;
 import org.junit.Test;
+import org.springframework.data.redis.connection.RedisConnection;
 import org.springframework.data.redis.connection.RedisSentinelConfiguration;
 import org.springframework.data.redis.test.util.RedisSentinelRule;
 
@@ -47,7 +48,7 @@ public void tearDown() {
 		}
 	}
 
-	@Test // DATAREDIS-574
+	@Test // DATAREDIS-574, DATAREDIS-765
 	public void shouldInitializeWithSentinelConfiguration() {
 
 		JedisClientConfiguration clientConfiguration = JedisClientConfiguration.builder() //
@@ -57,7 +58,10 @@ public void shouldInitializeWithSentinelConfiguration() {
 		factory = new JedisConnectionFactory(SENTINEL_CONFIG, clientConfiguration);
 		factory.afterPropertiesSet();
 
-		assertThat(factory.getConnection().getClientName(), equalTo("clientName"));
+		RedisConnection connection = factory.getConnection();
+
+		assertThat(factory.getUsePool(), is(true));
+		assertThat(connection.getClientName(), equalTo("clientName"));
 	}
 
 	@Test // DATAREDIS-324

src/test/java/org/springframework/data/redis/connection/jedis/JedisConnectionFactoryUnitTests.java

@@ -75,6 +75,14 @@ public void shouldInitJedisPoolWhenNoSentinelConfigPresent() {
 		verify(connectionFactory, never()).createRedisSentinelPool(any(RedisSentinelConfiguration.class));
 	}
 
+	@Test(expected = IllegalStateException.class) // DATAREDIS-765
+	public void shouldRejectPoolDisablingWhenSentinelConfigPresent() {
+
+		connectionFactory = new JedisConnectionFactory(new RedisSentinelConfiguration());
+
+		connectionFactory.setUsePool(false);
+	}
+
 	@Test // DATAREDIS-315
 	public void shouldInitConnectionCorrectlyWhenClusterConfigPresent() {