diff --git a/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java b/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java
index 112e88bc..dc003f43 100644
--- a/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java
+++ b/src/main/java/io/vertx/redis/client/impl/RedisClusterConnection.java
@@ -353,7 +353,7 @@ void send(String endpoint, int retries, Request command, Completable<Response> h
         }
 
         try {
-          handler.succeed(send.result());
+          handler.complete(send.result(), send.cause());
         } catch (RuntimeException e) {
           LOG.error("Handler failure", e);
         }
@@ -534,7 +534,7 @@ private void batch(String endpoint, int retries, List<Request> commands, Complet
         }
 
         try {
-          handler.succeed(send.result());
+          handler.complete(send.result(), send.cause());
         } catch (RuntimeException e) {
           LOG.error("Handler failure", e);
         }