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

Ladicek · web-flow · commit 5c874ae8413f · 2024-10-21T15:26:11.000+02:00
fix RedisClusterConnection completion
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);
         }

Original file line number	Diff line number	Diff line change
`@@ -353,7 +353,7 @@ void send(String endpoint, int retries, Request command, Completable<Response> h`
`353`	`353`	`}`
`354`	`354`
`355`	`355`	`try {`
`356`		`- handler.succeed(send.result());`
	`356`	`+ handler.complete(send.result(), send.cause());`
`357`	`357`	`} catch (RuntimeException e) {`
`358`	`358`	`LOG.error("Handler failure", e);`
`359`	`359`	`}`
`@@ -534,7 +534,7 @@ private void batch(String endpoint, int retries, List<Request> commands, Complet`
`534`	`534`	`}`
`535`	`535`
`536`	`536`	`try {`
`537`		`- handler.succeed(send.result());`
	`537`	`+ handler.complete(send.result(), send.cause());`
`538`	`538`	`} catch (RuntimeException e) {`
`539`	`539`	`LOG.error("Handler failure", e);`
`540`	`540`	`}`