refactoring

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

@@ -493,7 +493,7 @@ public class RedissonClusterConnection extends RedissonConnection implements Red
         };
 
         for (Entry<MasterSlaveEntry, List<byte[]>> entry : range2key.entrySet()) {
-            CommandBatchService es = new CommandBatchService(executorService.getConnectionManager());
+            CommandBatchService es = new CommandBatchService(executorService);
             for (byte[] key : entry.getValue()) {
                 es.writeAsync(entry.getKey(), null, command, key);
             }

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

@@ -498,7 +498,7 @@ public class RedissonClusterConnection extends RedissonConnection implements Red
         };
 
         for (Entry<MasterSlaveEntry, List<byte[]>> entry : range2key.entrySet()) {
-            CommandBatchService es = new CommandBatchService(executorService.getConnectionManager());
+            CommandBatchService es = new CommandBatchService(executorService);
             for (byte[] key : entry.getValue()) {
                 es.writeAsync(entry.getKey(), null, command, key);
             }

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

@@ -547,7 +547,7 @@ public class RedissonClusterConnection extends RedissonConnection implements Def
         };
 
         for (Entry<MasterSlaveEntry, List<byte[]>> entry : range2key.entrySet()) {
-            CommandBatchService es = new CommandBatchService(executorService.getConnectionManager());
+            CommandBatchService es = new CommandBatchService(executorService);
             for (byte[] key : entry.getValue()) {
                 es.writeAsync(entry.getKey(), null, command, key);
             }

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

@@ -547,7 +547,7 @@ public class RedissonClusterConnection extends RedissonConnection implements Def
         };
 
         for (Entry<MasterSlaveEntry, List<byte[]>> entry : range2key.entrySet()) {
-            CommandBatchService es = new CommandBatchService(executorService.getConnectionManager());
+            CommandBatchService es = new CommandBatchService(executorService);
             for (byte[] key : entry.getValue()) {
                 es.writeAsync(entry.getKey(), null, command, key);
             }

redisson-spring-data/redisson-spring-data-24/src/main/java/org/redisson/spring/data/connection/RedissonClusterConnection.java

@@ -547,7 +547,7 @@ public class RedissonClusterConnection extends RedissonConnection implements Def
         };
 
         for (Entry<MasterSlaveEntry, List<byte[]>> entry : range2key.entrySet()) {
-            CommandBatchService es = new CommandBatchService(executorService.getConnectionManager());
+            CommandBatchService es = new CommandBatchService(executorService);
             for (byte[] key : entry.getValue()) {
                 es.writeAsync(entry.getKey(), null, command, key);
             }