- ActorSystem system = ActorSystem.create("cluster-test", ConfigFactory.load().getConfig(akkaConfig));
- Cluster.get(system).join(MEMBER_1_ADDRESS);
+ Config baseConfig = ConfigFactory.load();
+ Config config;
+ if (useAkkaArtery) {
+ config = baseConfig.getConfig(akkaConfig);
+ } else {
+ config = baseConfig.getConfig(akkaConfig + "-without-artery")
+ .withFallback(baseConfig.getConfig(akkaConfig));
+ }
+
+ ActorSystem system = ActorSystem.create("cluster-test", config);
+ String member1Address = useAkkaArtery ? MEMBER_1_ADDRESS : MEMBER_1_ADDRESS.replace("akka", "akka.tcp");
+ Cluster.get(system).join(AddressFromURIString.parse(member1Address));