From 5d5d3c380ab36600ca0bb82fadc916d5e93c99db Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Sun, 20 Dec 2020 12:13:25 +0100 Subject: [PATCH] Update to Vert.X 4.0.0 --- pom.xml | 59 ++++++++++++------- .../td/middle/TdClusterManager.java | 18 +++--- 2 files changed, 46 insertions(+), 31 deletions(-) diff --git a/pom.xml b/pom.xml index 2bfbf3d..b19f595 100644 --- a/pom.xml +++ b/pom.xml @@ -9,9 +9,11 @@ UTF-8 0-SNAPSHOT - 11 11 + + 4.0.0 + 5.4.0 @@ -47,26 +49,51 @@ scm:git:https://git.ignuranza.net/tdlight-team/tdlib-session-container.git HEAD + + + + io.vertx + vertx-stack-depchain + ${vertx.version} + pom + import + + + - - io.vertx - vertx-core - 3.9.3 - io.vertx vertx-hazelcast - 3.9.3 + ${vertx.version} io.vertx - vertx-reactive-streams - 3.9.3 + vertx-junit5 + ${vertx.version} + test + + + org.junit.jupiter + junit-jupiter-api + ${junit-jupiter.version} + test + + + org.hamcrest + hamcrest-core + + + + + org.junit.jupiter + junit-jupiter-engine + ${junit-jupiter.version} + test io.vertx vertx-circuit-breaker - 3.9.3 + ${vertx.version} io.projectreactor @@ -120,18 +147,6 @@ fastutil 8.3.1 - - org.junit.jupiter - junit-jupiter-api - RELEASE - test - - - org.hamcrest - hamcrest-core - - - com.google.code.gson gson diff --git a/src/main/java/it/tdlight/tdlibsession/td/middle/TdClusterManager.java b/src/main/java/it/tdlight/tdlibsession/td/middle/TdClusterManager.java index b6e22c3..e5068ba 100644 --- a/src/main/java/it/tdlight/tdlibsession/td/middle/TdClusterManager.java +++ b/src/main/java/it/tdlight/tdlibsession/td/middle/TdClusterManager.java @@ -1,13 +1,12 @@ package it.tdlight.tdlibsession.td.middle; import com.hazelcast.config.Config; +import com.hazelcast.config.EvictionConfig; import com.hazelcast.config.EvictionPolicy; -import com.hazelcast.config.GroupConfig; import com.hazelcast.config.MapConfig; -import com.hazelcast.config.MaxSizeConfig; -import com.hazelcast.config.MaxSizeConfig.MaxSizePolicy; +import com.hazelcast.config.MaxSizePolicy; import com.hazelcast.config.MergePolicyConfig; -import com.hazelcast.config.SemaphoreConfig; +import com.hazelcast.config.cp.SemaphoreConfig; import io.vertx.core.DeploymentOptions; import io.vertx.core.Handler; import io.vertx.core.Vertx; @@ -105,10 +104,12 @@ public class TdClusterManager { .setBackupCount(1) .setTimeToLiveSeconds(0) .setMaxIdleSeconds(0) - .setEvictionPolicy(EvictionPolicy.NONE) - .setMaxSizeConfig(new MaxSizeConfig().setMaxSizePolicy(MaxSizePolicy.PER_NODE).setSize(0)) + .setEvictionConfig(new EvictionConfig() + .setMaxSizePolicy(MaxSizePolicy.PER_NODE) + .setEvictionPolicy(EvictionPolicy.NONE) + .setSize(0)) .setMergePolicyConfig(new MergePolicyConfig().setPolicy("com.hazelcast.map.merge.LatestUpdateMapMergePolicy"))); - cfg.setSemaphoreConfigs(Map.of("__vertx.*", new SemaphoreConfig().setInitialPermits(1))); + cfg.getCPSubsystemConfig().setSemaphoreConfigs(Map.of("__vertx.*", new SemaphoreConfig().setInitialPermits(1))); cfg.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(false); cfg.getNetworkConfig().getJoin().getAwsConfig().setEnabled(false); cfg.getNetworkConfig().getJoin().getTcpIpConfig().setEnabled(true); @@ -122,7 +123,7 @@ public class TdClusterManager { cfg.setProperty("hazelcast.wait.seconds.before.join", "0"); cfg.setProperty("hazelcast.tcp.join.port.try.count", "5"); cfg.setProperty("hazelcast.socket.bind.any", "false"); - cfg.setGroupConfig(new GroupConfig().setName("dev").setPassword("HzPasswordsAreDeprecated")); + cfg.setClusterName("tdlib-session-container"); mgr = new HazelcastClusterManager(cfg); vertxOptions.setClusterManager(mgr); vertxOptions.getEventBusOptions().setConnectTimeout(120000); @@ -139,7 +140,6 @@ public class TdClusterManager { } else { mgr = null; vertxOptions.setClusterManager(null); - vertxOptions.getEventBusOptions().setClustered(false); } return Mono