Merge pull request #481 from Ladicek/fix-cluster-connection-completion

fix RedisClusterConnection completion
vert-x3 · Oct 21, 2024 · 5c874ae · 5c874ae
2 parents 3ccfc19 + f9168e3
commit 5c874ae
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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);
         }