Return a cluster connection if cluster config

Signed-off-by: Chris Eager <christian@turo.com>

redisson-spring-data/redisson-spring-data-17/src/main/java/org/redisson/spring/data/connection/RedissonConnectionFactory.java

@@ -95,6 +95,9 @@ public class RedissonConnectionFactory implements RedisConnectionFactory, Initia
 
     @Override
     public RedisConnection getConnection() {
+        if (redisson.getConfig().isClusterConfig()) {
+            return new RedissonClusterConnection(redisson);
+        }
         return new RedissonConnection(redisson);
     }
 

redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnectionFactory.java

@@ -102,6 +102,9 @@ public class RedissonConnectionFactory implements RedisConnectionFactory,
 
     @Override
     public RedisConnection getConnection() {
+        if (redisson.getConfig().isClusterConfig()) {
+            return new RedissonClusterConnection(redisson);
+        }
         return new RedissonConnection(redisson);
     }
 

redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnectionFactory.java

@@ -100,6 +100,9 @@ public class RedissonConnectionFactory implements RedisConnectionFactory,
 
     @Override
     public RedisConnection getConnection() {
+        if (redisson.getConfig().isClusterConfig()) {
+            return new RedissonClusterConnection(redisson);
+        }
         return new RedissonConnection(redisson);
     }
 

redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnectionFactory.java

@@ -100,6 +100,9 @@ public class RedissonConnectionFactory implements RedisConnectionFactory,
 
     @Override
     public RedisConnection getConnection() {
+        if (redisson.getConfig().isClusterConfig()) {
+            return new RedissonClusterConnection(redisson);
+        }
         return new RedissonConnection(redisson);
     }
 

redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnectionFactory.java

@@ -106,6 +106,9 @@ public class RedissonConnectionFactory implements RedisConnectionFactory,
 
     @Override
     public RedisConnection getConnection() {
+        if (redisson.getConfig().isClusterConfig()) {
+            return new RedissonClusterConnection(redisson);
+        }
         return new RedissonConnection(redisson);
     }
 

redisson-spring-data/redisson-spring-data-23/src/main/java/org/redisson/spring/data/connection/RedissonConnectionFactory.java

@@ -106,6 +106,9 @@ public class RedissonConnectionFactory implements RedisConnectionFactory,
 
     @Override
     public RedisConnection getConnection() {
+        if (redisson.getConfig().isClusterConfig()) {
+            return new RedissonClusterConnection(redisson);
+        }
         return new RedissonConnection(redisson);
     }