From 56a568e4074800870113b7691257a8627c39de82 Mon Sep 17 00:00:00 2001 From: Julien Viet Date: Wed, 19 Jul 2023 15:42:29 +0200 Subject: [PATCH] Update to executeBlocking API change --- src/test/java/io/vertx/test/redis/RedisClusterClientIT.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/test/java/io/vertx/test/redis/RedisClusterClientIT.java b/src/test/java/io/vertx/test/redis/RedisClusterClientIT.java index 8a190f14..1576f08c 100644 --- a/src/test/java/io/vertx/test/redis/RedisClusterClientIT.java +++ b/src/test/java/io/vertx/test/redis/RedisClusterClientIT.java @@ -106,7 +106,7 @@ public RedisClusterClientIT(String image, String password) { @Before public void before(TestContext should) { final Async before = should.async(); - rule.vertx().executeBlocking(handler -> { + rule.vertx().executeBlocking(() -> { List> containerList = new ArrayList<>(); containerList.add(redis7000); containerList.add(redis7001); @@ -123,7 +123,7 @@ public void before(TestContext should) { String connectionString = stringBuilder.substring(0, stringBuilder.length() - 1); redisCli.setCommand(String.format("redis-cli --cluster create %s --cluster-replicas 1 --cluster-yes%s", connectionString, password == null ? "" : " -a " + password)); redisCli.start(); - handler.complete(); + return null; }).onSuccess(handler -> { client = Redis.createClient( rule.vertx(), new RedisOptions()