fix: use tcpip config joiner configuration

Author: igdianov

activiti-cloud-messages-service/starters/hazelcast/src/main/java/org/activiti/cloud/starter/messages/hazelcast/HazelcastMessageStoreAutoConfiguration.java

@@ -46,8 +46,7 @@ public Config hazelcastConfig() {
         Config config = new Config();
 
         config.getCPSubsystemConfig()
-              .setCPMemberCount(3)
-              .setGroupSize(3);
+              .setCPMemberCount(3);
 
         return config;
     }

activiti-cloud-messages-service/starters/hazelcast/src/test/java/org/activiti/cloud/starter/messages/test/hazelcast/HazelcastMessageStoreIT.java

@@ -18,17 +18,18 @@
 import static org.assertj.core.api.Assertions.assertThat;
 
 import org.activiti.cloud.services.messages.tests.AbstractMessagesCoreIntegrationTests;
-import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.Test;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.test.context.TestConfiguration;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Scope;
 import org.springframework.integration.hazelcast.store.HazelcastMessageStore;
 
 import com.hazelcast.config.Config;
+import com.hazelcast.config.JoinConfig;
+import com.hazelcast.config.NetworkConfig;
 import com.hazelcast.core.Hazelcast;
 import com.hazelcast.core.HazelcastInstance;
-import com.hazelcast.instance.impl.HazelcastInstanceFactory;
 
 public class HazelcastMessageStoreIT extends AbstractMessagesCoreIntegrationTests {
 
@@ -41,27 +42,55 @@ static class MessagesApplication {
     static class HazelcastConfiguration {
 
         @Bean
+        @Scope("prototype")
+        public Config hazelcastConfig() {
+            Config config = new Config();
+
+            config.getCPSubsystemConfig()
+                  .setCPMemberCount(3);
+
+            NetworkConfig network = config.getNetworkConfig()
+                                          .setPortAutoIncrement(true);
+            network.setPort(5701)
+                   .setPortCount(20);
+
+            JoinConfig join = network.getJoin();
+
+            join.getMulticastConfig()
+                .setEnabled(false);
+
+            join.getTcpIpConfig()
+                .setEnabled(true)
+                .addMember("localhost");
+
+            return config;
+        }
+
+        @Bean(destroyMethod = "shutdown")
         public HazelcastInstance hazelcastInstance(Config hazelcastConfig) {
+            hazelcastConfig.getNetworkConfig()
+                           .setPublicAddress("localhost:5701");
+
             return Hazelcast.newHazelcastInstance(hazelcastConfig);
         }
 
-        @Bean
+        @Bean(destroyMethod = "shutdown")
         public HazelcastInstance hazelcastInstance2(Config hazelcastConfig) {
+            hazelcastConfig.getNetworkConfig()
+                           .setPublicAddress("localhost:5702");
+
             return Hazelcast.newHazelcastInstance(hazelcastConfig);
         }
 
-        @Bean
+        @Bean(destroyMethod = "shutdown")
         public HazelcastInstance hazelcastInstance3(Config hazelcastConfig) {
+            hazelcastConfig.getNetworkConfig()
+                           .setPublicAddress("localhost:5703");
+
             return Hazelcast.newHazelcastInstance(hazelcastConfig);
         }
     }
 
-    @AfterAll
-    public static void afterAll() {
-        HazelcastInstanceFactory.terminateAll();
-    }
-
-
     @Test
     public void testMessageStore() throws Exception {
         assertThat(this.aggregatingMessageHandler.getMessageStore()).isInstanceOf(HazelcastMessageStore.class);