DATAREDIS-552 - Support client name configuration for JedisConnectionFactory.

Motivation: JedisConnectionFactory should support setting clientName for Jedis connections so to improve troubleshooting. Result: Easier to troubleshooting with connection name. Original pull request: spring-projects#219.

Author: jiafu1115

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

@@ -63,6 +63,7 @@
  * @author Thomas Darimont
  * @author Christoph Strobl
  * @author Mark Paluch
+ * @author Fu Jian
  */
 public class JedisConnectionFactory implements InitializingBean, DisposableBean, RedisConnectionFactory {
 
@@ -101,6 +102,7 @@ public class JedisConnectionFactory implements InitializingBean, DisposableBean,
 private Pool<Jedis> pool;
 private JedisPoolConfig poolConfig = new JedisPoolConfig();
 private int dbIndex = 0;
+private String clientName;
 private boolean convertPipelineAndTxResults = true;
 private RedisSentinelConfiguration sentinelConfig;
 private RedisClusterConfiguration clusterConfig;
@@ -255,7 +257,7 @@ private Pool<Jedis> createPool() {
 protected Pool<Jedis> createRedisSentinelPool(RedisSentinelConfiguration config) {
 return new JedisSentinelPool(config.getMaster().getName(), convertToJedisSentinelSet(config.getSentinels()),
 getPoolConfig() != null ? getPoolConfig() : new JedisPoolConfig(), getTimeoutFrom(getShardInfo()),
-getShardInfo().getPassword());
+getShardInfo().getPassword(), Protocol.DEFAULT_DATABASE, clientName);
 }
 
 /**
@@ -267,7 +269,7 @@ protected Pool<Jedis> createRedisSentinelPool(RedisSentinelConfiguration config)
 protected Pool<Jedis> createRedisPool() {
 
 return new JedisPool(getPoolConfig(), getShardInfo().getHost(), getShardInfo().getPort(),
-getTimeoutFrom(getShardInfo()), getShardInfo().getPassword(), useSsl);
+getTimeoutFrom(getShardInfo()), getShardInfo().getPassword(), Protocol.DEFAULT_DATABASE, clientName, useSsl);
 }
 
 private JedisCluster createCluster() {
@@ -530,6 +532,24 @@ public void setDatabase(int index) {
 Assert.isTrue(index >= 0, "invalid DB index (a positive index required)");
 this.dbIndex = index;
 }
+
+/**
+ * Returns the client name.
+ * 
+ * @return Returns the client name
+ */
+public String getClientName() {
+return clientName;
+}
+
+/**
+ * Sets the client name used by this connection factory. Default is empty.
+ * 
+ * @param clientName client name
+ */
+public void setClientName(String clientName) {
+this.clientName = clientName;
+}
 
 /**
  * Specifies if pipelined results should be converted to the expected data type. If false, results of

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

@@ -39,6 +39,7 @@ public class JedisConnectionFactoryTests {
 @Before
 public void setUp() {
 factory = new JedisConnectionFactory(SENTINEL_CONFIG);
+factory.setClientName("clientName");
 factory.afterPropertiesSet();
 }
 
@@ -54,4 +55,9 @@ public void tearDown() {
 public void shouldSendCommandCorrectlyViaConnectionFactoryUsingSentinel() {
 assertThat(factory.getConnection().ping(), equalTo("PONG"));
 }
+
+@Test
+public void getClientNameShouldEqualWithFactorySetting() {
+assertThat(factory.getConnection().getClientName(), equalTo("clientName"));
+}
 }