diff --git a/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
index d7bb82410..5faa05d1a 100644
--- a/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
+++ b/redisson-spring-data/redisson-spring-data-16/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
@@ -237,11 +237,11 @@ public class RedissonConnection extends AbstractRedisConnection {
         final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
         final AtomicLong count = new AtomicLong();
         final AtomicLong executed = new AtomicLong(range2key.size());
-        BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
+        BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
             @Override
-            public void accept(List<?> r, Throwable u) {
+            public void accept(BatchResult<?> r, Throwable u) {
                 if (u == null) {    
-                    List<Long> result = (List<Long>) r;
+                    List<Long> result = (List<Long>) r.getResponses();
                     for (Long res : result) {
                         if (res != null) {
                             count.addAndGet(res);
@@ -261,7 +261,7 @@ public class RedissonConnection extends AbstractRedisConnection {
                 es.writeAsync(entry.getKey(), null, command, key);
             }
 
-            RFuture<List<?>> future = es.executeAsync();
+            RFuture<BatchResult<?>> future = es.executeAsync();
             future.onComplete(listener);
         }
 
diff --git a/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
index 9c62122b3..6a59fb7eb 100644
--- a/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
+++ b/redisson-spring-data/redisson-spring-data-18/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
@@ -273,11 +273,11 @@ public class RedissonConnection extends AbstractRedisConnection {
         final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
         final AtomicLong count = new AtomicLong();
         final AtomicLong executed = new AtomicLong(range2key.size());
-        BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
+        BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
             @Override
-            public void accept(List<?> r, Throwable u) {
+            public void accept(BatchResult<?> r, Throwable u) {
                 if (u == null) {    
-                    List<Long> result = (List<Long>) r;
+                    List<Long> result = (List<Long>) r.getResponses();
                     for (Long res : result) {
                         if (res != null) {
                             count.addAndGet(res);
@@ -297,7 +297,7 @@ public class RedissonConnection extends AbstractRedisConnection {
                 es.writeAsync(entry.getKey(), null, command, key);
             }
 
-            RFuture<List<?>> future = es.executeAsync();
+            RFuture<BatchResult<?>> future = es.executeAsync();
             future.onComplete(listener);
         }
 
diff --git a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
index 819b27f59..785c967ca 100644
--- a/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
+++ b/redisson-spring-data/redisson-spring-data-20/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
@@ -240,11 +240,11 @@ public class RedissonConnection extends AbstractRedisConnection {
         final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
         final AtomicLong count = new AtomicLong();
         final AtomicLong executed = new AtomicLong(range2key.size());
-        BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
+        BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
             @Override
-            public void accept(List<?> r, Throwable u) {
+            public void accept(BatchResult<?> r, Throwable u) {
                 if (u == null) {    
-                    List<Long> result = (List<Long>) r;
+                    List<Long> result = (List<Long>) r.getResponses();
                     for (Long res : result) {
                         if (res != null) {
                             count.addAndGet(res);
@@ -264,7 +264,7 @@ public class RedissonConnection extends AbstractRedisConnection {
                 es.writeAsync(entry.getKey(), null, command, key);
             }
 
-            RFuture<List<?>> future = es.executeAsync();
+            RFuture<BatchResult<?>> future = es.executeAsync();
             future.onComplete(listener);
         }
 
diff --git a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
index 9a0334db1..a476904ae 100644
--- a/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
+++ b/redisson-spring-data/redisson-spring-data-21/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
@@ -270,11 +270,11 @@ public class RedissonConnection extends AbstractRedisConnection {
         final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
         final AtomicLong count = new AtomicLong();
         final AtomicLong executed = new AtomicLong(range2key.size());
-        BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
+        BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
             @Override
-            public void accept(List<?> r, Throwable u) {
+            public void accept(BatchResult<?> r, Throwable u) {
                 if (u == null) {    
-                    List<Long> result = (List<Long>) r;
+                    List<Long> result = (List<Long>) r.getResponses();
                     for (Long res : result) {
                         if (res != null) {
                             count.addAndGet(res);
@@ -294,7 +294,7 @@ public class RedissonConnection extends AbstractRedisConnection {
                 es.writeAsync(entry.getKey(), null, command, key);
             }
 
-            RFuture<List<?>> future = es.executeAsync();
+            RFuture<BatchResult<?>> future = es.executeAsync();
             future.onComplete(listener);
         }
 
diff --git a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
index 146d63dc1..4c5fa1ee8 100644
--- a/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
+++ b/redisson-spring-data/redisson-spring-data-22/src/main/java/org/redisson/spring/data/connection/RedissonConnection.java
@@ -262,11 +262,11 @@ public class RedissonConnection extends AbstractRedisConnection {
         final AtomicReference<Throwable> failed = new AtomicReference<Throwable>();
         final AtomicLong count = new AtomicLong();
         final AtomicLong executed = new AtomicLong(range2key.size());
-        BiConsumer<List<?>, Throwable> listener = new BiConsumer<List<?>, Throwable>() {
+        BiConsumer<BatchResult<?>, Throwable> listener = new BiConsumer<BatchResult<?>, Throwable>() {
             @Override
-            public void accept(List<?> r, Throwable u) {
+            public void accept(BatchResult<?> r, Throwable u) {
                 if (u == null) {    
-                    List<Long> result = (List<Long>) r;
+                    List<Long> result = (List<Long>) r.getResponses();
                     for (Long res : result) {
                         if (res != null) {
                             count.addAndGet(res);
@@ -286,7 +286,7 @@ public class RedissonConnection extends AbstractRedisConnection {
                 es.writeAsync(entry.getKey(), null, command, key);
             }
 
-            RFuture<List<?>> future = es.executeAsync();
+            RFuture<BatchResult<?>> future = es.executeAsync();
             future.onComplete(listener);
         }