allow for naming connections

src/main/java/org/redisson/BaseConfig.java

@@ -44,6 +44,11 @@ class BaseConfig<T extends BaseConfig<T>> {
      */
     private int subscriptionsPerConnection = 5;
 
+    /**
+     * Name of client connection
+     */
+    private String clientName;
+
     BaseConfig() {
     }
 
@@ -145,4 +150,15 @@ class BaseConfig<T extends BaseConfig<T>> {
         return timeout;
     }
 
+    /**
+     * Name for client connection
+     */
+    public String getClientName() {
+        return clientName;
+    }
+
+    public T setClientName(String clientName) {
+        this.clientName = clientName;
+        return (T) this;
+    }
 }

src/main/java/org/redisson/connection/BaseLoadBalancer.java

@@ -144,6 +144,9 @@ abstract class BaseLoadBalancer implements LoadBalancer {
                     if (config.getDatabase() != 0) {
                         conn.select(config.getDatabase());
                     }
+                    if (config.getClientName() != null) {
+                        conn.clientSetname(config.getClientName());
+                    }
 
                     entry.registerSubscribeConnection(conn);
                     return conn;
@@ -184,6 +187,9 @@ abstract class BaseLoadBalancer implements LoadBalancer {
                     if (config.getDatabase() != 0) {
                         conn.select(config.getDatabase());
                     }
+                    if (config.getClientName() != null) {
+                        conn.clientSetname(config.getClientName());
+                    }
 
                     return conn;
                 } catch (RedisConnectionException e) {

src/main/java/org/redisson/connection/ClusterConnectionManager.java

@@ -221,6 +221,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
         c.setLoadBalancer(cfg.getLoadBalancer());
         c.setPassword(cfg.getPassword());
         c.setDatabase(cfg.getDatabase());
+        c.setClientName(cfg.getClientName());
         c.setMasterConnectionPoolSize(cfg.getMasterConnectionPoolSize());
         c.setSlaveConnectionPoolSize(cfg.getSlaveConnectionPoolSize());
         c.setSlaveSubscriptionConnectionPoolSize(cfg.getSlaveSubscriptionConnectionPoolSize());

src/main/java/org/redisson/connection/MasterSlaveEntry.java

@@ -131,6 +131,9 @@ public class MasterSlaveEntry {
             if (config.getDatabase() != 0) {
                 conn.select(config.getDatabase());
             }
+            if (config.getClientName() != null) {
+                conn.clientSetname((K) config.getClientName());
+            }
             return conn;
         } catch (RedisConnectionException e) {
             masterEntry.getConnectionsSemaphore().release();

src/main/java/org/redisson/connection/SingleConnectionManager.java

@@ -29,6 +29,7 @@ public class SingleConnectionManager extends MasterSlaveConnectionManager {
         newconfig.setTimeout(cfg.getTimeout());
         newconfig.setPassword(cfg.getPassword());
         newconfig.setDatabase(cfg.getDatabase());
+        newconfig.setClientName(cfg.getClientName());
         newconfig.setMasterAddress(addr);
         newconfig.setMasterConnectionPoolSize(cfg.getConnectionPoolSize());
         newconfig.setSubscriptionsPerConnection(cfg.getSubscriptionsPerConnection());

src/main/java/org/redisson/connection/SingleEntry.java

@@ -66,6 +66,9 @@ public class SingleEntry extends MasterSlaveEntry {
             if (config.getDatabase() != 0) {
                 conn.select(config.getDatabase());
             }
+            if (config.getClientName() != null) {
+                conn.clientSetname(config.getClientName());
+            }
             return conn;
         } catch (RedisConnectionException e) {
             ((SubscribesConnectionEntry)masterEntry).getSubscribeConnectionsSemaphore().release();