Update vertx-config-redis that was still using some deprecated methods

vert-x3 · Mar 16, 2023 · a8592e0 · a8592e0
1 parent 6ceb237
commit a8592e0
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/.DS_Store b/.DS_Store
diff --git a/vertx-config-redis/src/test/java/io/vertx/config/redis/Redis6ConfigStoreTest.java b/vertx-config-redis/src/test/java/io/vertx/config/redis/Redis6ConfigStoreTest.java
@@ -66,7 +66,7 @@ public void before(TestContext should) {
       rule.vertx(),
       new RedisOptions().setConnectionString("redis://" + redis.getContainerIpAddress() + ":" + redis.getFirstMappedPort() + "?client=tester"));
 
-    client.connect(onConnect -> {
+    client.connect().onComplete(onConnect -> {
       should.assertTrue(onConnect.succeeded());
       onConnect.result().close();
       before.complete();
@@ -142,7 +142,7 @@ public void getWithConfiguredKey(TestContext tc) throws Exception {
 
   private void writeSomeConf(String key, Handler<AsyncResult<Void>> handler) {
     RedisAPI api = RedisAPI.api(client);
-    api.hmset(Arrays.asList(key, "some-key", "some-value"), ar -> {
+    api.hmset(Arrays.asList(key, "some-key", "some-value")).onComplete(ar -> {
       if (ar.succeeded()) {
         handler.handle(Future.succeededFuture());
       } else {

diff --git a/vertx-config-redis/src/test/java/io/vertx/config/redis/RedisConfigStoreTest.java b/vertx-config-redis/src/test/java/io/vertx/config/redis/RedisConfigStoreTest.java
@@ -66,7 +66,7 @@ public void before(TestContext should) {
       rule.vertx(),
       new RedisOptions().setConnectionString("redis://" + redis.getContainerIpAddress() + ":" + redis.getFirstMappedPort() + "?client=tester"));
 
-    client.connect(onConnect -> {
+    client.connect().onComplete(onConnect -> {
       should.assertTrue(onConnect.succeeded());
       onConnect.result().close();
       before.complete();
@@ -142,7 +142,7 @@ public void getWithConfiguredKey(TestContext tc) throws Exception {
 
   private void writeSomeConf(String key, Handler<AsyncResult<Void>> handler) {
     RedisAPI api = RedisAPI.api(client);
-    api.hmset(Arrays.asList(key, "some-key", "some-value"), ar -> {
+    api.hmset(Arrays.asList(key, "some-key", "some-value")).onComplete(ar -> {
       if (ar.succeeded()) {
         handler.handle(Future.succeededFuture());
       } else {