max-idle test

max-idle-test

    public static void main(String[] args) throws Exception {
        final Config config = new Config();
        final MapConfig mapConfig = config.getMapConfig("default");
        mapConfig.setBackupCount(0).setAsyncBackupCount(1).setMaxIdleSeconds(10);

        final HazelcastInstance instance1 = Hazelcast.newHazelcastInstance(config);
        final HazelcastInstance instance2 = Hazelcast.newHazelcastInstance(config);
        final IMap<Object, Object> map = instance1.getMap("default");


        String val = "val";
        for (int i = 0; i < 1000; i++) {
            map.put(i, val);
        }

        int i = 1;

        while (true) {
            printStats(instance1, instance2, i++);
            Thread.sleep(5000);
        }

    }

    static void printStats(HazelcastInstance instance1, HazelcastInstance instance2, int counter) {
        final LocalMapStats stats1 = instance1.getMap("default").getLocalMapStats();
        System.err.println("---------------------------------------- counter: " + counter);
        System.err.println("instance1 backup: " + stats1.getBackupEntryCount());
        System.err.println("instance1    own: " + stats1.getOwnedEntryCount());

        final LocalMapStats stats2 = instance2.getMap("default").getLocalMapStats();
        System.err.println("instance2 backup: " + stats2.getBackupEntryCount());
        System.err.println("instance2    own: " + stats2.getOwnedEntryCount());

        System.err.println("");
    }