DATAREDIS-476 - Polishing.

Add author and getter method for SSL property. Apply formatting. Create test to validate SSL setting is set correctly in the lettuce driver. Original pull request: spring-projects#177.

Author: mp911de

src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactory.java

@@ -69,6 +69,7 @@
  * @author Jennifer Hickey
  * @author Thomas Darimont
  * @author Mark Paluch
+ * @author Balázs Németh
  */
 public class LettuceConnectionFactory implements InitializingBean, DisposableBean, RedisConnectionFactory {
 
@@ -143,7 +144,6 @@ public LettuceConnectionFactory(LettucePool pool) {
  */
 public void afterPropertiesSet() {
 this.client = createRedisClient();
-
 }
 
 /*
@@ -311,11 +311,22 @@ public void setTimeout(long timeout) {
 
 /**
  * Sets to use SSL connection
+ *
+ * @param useSsl {@literal true} to use SSL.
  */
-public void setUseSsl(boolean useSsl){
+public void setUseSsl(boolean useSsl) {
 this.useSsl = useSsl;
 }
 
+/**
+ * Returns whether to use SSL.
+ *
+ * @return
+ */
+public boolean isUseSsl() {
+return useSsl;
+}
+
 /**
  * Indicates if validation of the native Lettuce connection is enabled
  *

src/test/java/org/springframework/data/redis/connection/lettuce/LettuceConnectionFactoryUnitTests.java

@@ -30,6 +30,7 @@
 import org.springframework.data.redis.connection.RedisClusterConfiguration;
 
 import com.lambdaworks.redis.AbstractRedisClient;
+import com.lambdaworks.redis.RedisClient;
 import com.lambdaworks.redis.RedisURI;
 import com.lambdaworks.redis.cluster.RedisClusterClient;
 
@@ -127,4 +128,26 @@ public void clusterClientShouldInitializeWithoutClientResources() {
 AbstractRedisClient client = (AbstractRedisClient) getField(connectionFactory, "client");
 assertThat(client, instanceOf(RedisClusterClient.class));
 }
+
+/**
+ * @see DATAREDIS-476
+ */
+@Test
+public void sslShouldBeSetCorrectlyOnClient() {
+
+LettuceConnectionFactory connectionFactory = new LettuceConnectionFactory();
+connectionFactory.setClientResources(LettuceTestClientResources.getSharedClientResources());
+connectionFactory.setUseSsl(true);
+connectionFactory.afterPropertiesSet();
+ConnectionFactoryTracker.add(connectionFactory);
+
+AbstractRedisClient client = (AbstractRedisClient) getField(connectionFactory, "client");
+assertThat(client, instanceOf(RedisClient.class));
+
+RedisURI redisUri = (RedisURI) getField(client, "redisURI");
+
+assertThat(redisUri.isSsl(), is(true));
+assertThat(connectionFactory.isUseSsl(), is(true));
+}
+
 }