2.x client reconnect

client-reconnect

public class HazelcastClientUtils {

    private static HazelcastClient client = null;

    public static void init() {
        new Thread() {
            public void run() {
                while (true) {
                    if (client == null) {
                        createClient();
                        continue;
                    }
                    if (client.isActive()) {
                        try {
                            Thread.sleep(1000);
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        continue;
                    }
                    client.getLifecycleService().shutdown();
                    createClient();
                }
            }
        }.start();
    }

    private static void createClient() {
        final ClientConfig clientConfig = new ClientConfig();
        clientConfig.setInitialConnectionAttemptLimit(1);
        clientConfig.setReconnectionAttemptLimit(0);
        try {
            client = HazelcastClient.newHazelcastClient(clientConfig);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    public static IMap getMap(String name) {
        return client.getMap(name);
    }

}