alexterman/Main.java

## Main.java
package initial;

import com.hazelcast.config.Config;
import com.hazelcast.config.EntryListenerConfig;
import com.hazelcast.config.MapConfig;
import com.hazelcast.core.EntryEvent;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.core.IMap;
import com.hazelcast.map.listener.EntryEvictedListener;

import java.io.Serializable;
import java.time.LocalTime;
import java.util.Collections;

import static java.lang.System.setProperty;

public class Main {

    private static final int TTL = 5;

    public static void main(String[] args) throws InterruptedException {

        setProperty("hazelcast.internal.map.expiration.task.period.seconds", "1");

        EntryListenerConfig entryListenerConfig = createEntryListenerConfig();
        MapConfig mapConfig = createMapConfig(entryListenerConfig);
        Config config = createInstanceConfig(mapConfig);

        HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);

        final IMap<String, Order> map = instance.getMap("testMap");

        insertData(map);
    }

    private static Config createInstanceConfig(MapConfig mapConfig) {
        Config config = new Config();
        config.setInstanceName("testInstance");
        config.addMapConfig(mapConfig);
        return config;
    }

    private static EntryListenerConfig createEntryListenerConfig() {
        EntryListenerConfig entryListenerConfig = new EntryListenerConfig();
        entryListenerConfig.setImplementation(new EvictionListener());
        return entryListenerConfig;
    }

    private static MapConfig createMapConfig(EntryListenerConfig entryListenerConfig) {
        MapConfig mapConfig = new MapConfig();
        mapConfig.setName("testMap");
        mapConfig.setMaxIdleSeconds(TTL);
        mapConfig.setEntryListenerConfigs(Collections.singletonList(entryListenerConfig));
        return mapConfig;
    }

    private static void insertData(IMap<String, Order> map) {
        for (int i = 0; i < 100; i++) {
            map.put(i + "_", new Order());
        }
        System.err.println("finished inserting to map");
    }

    private static class Order implements Serializable {
        public LocalTime localTime;

        public Order() {
            this.localTime = LocalTime.now();
        }
    }

    private static class EvictionListener implements EntryEvictedListener<String, Order> {
        @Override
        public void entryEvicted(EntryEvent<String, Order> event) {
            final LocalTime now = LocalTime.now();
            System.err.println(event.getKey());
            System.err.println("time inserted:\t" + event.getOldValue().localTime);
            System.err.println("time evicted:\t" + now);
            System.err.println("");
        }
    }
}
	package initial;

	import com.hazelcast.config.Config;
	import com.hazelcast.config.EntryListenerConfig;
	import com.hazelcast.config.MapConfig;
	import com.hazelcast.core.EntryEvent;
	import com.hazelcast.core.Hazelcast;
	import com.hazelcast.core.HazelcastInstance;
	import com.hazelcast.core.IMap;
	import com.hazelcast.map.listener.EntryEvictedListener;

	import java.io.Serializable;
	import java.time.LocalTime;
	import java.util.Collections;

	import static java.lang.System.setProperty;

	public class Main {

	private static final int TTL = 5;

	public static void main(String[] args) throws InterruptedException {

	setProperty("hazelcast.internal.map.expiration.task.period.seconds", "1");

	EntryListenerConfig entryListenerConfig = createEntryListenerConfig();
	MapConfig mapConfig = createMapConfig(entryListenerConfig);
	Config config = createInstanceConfig(mapConfig);

	HazelcastInstance instance = Hazelcast.newHazelcastInstance(config);

	final IMap<String, Order> map = instance.getMap("testMap");

	insertData(map);
	}

	private static Config createInstanceConfig(MapConfig mapConfig) {
	Config config = new Config();
	config.setInstanceName("testInstance");
	config.addMapConfig(mapConfig);
	return config;
	}

	private static EntryListenerConfig createEntryListenerConfig() {
	EntryListenerConfig entryListenerConfig = new EntryListenerConfig();
	entryListenerConfig.setImplementation(new EvictionListener());
	return entryListenerConfig;
	}

	private static MapConfig createMapConfig(EntryListenerConfig entryListenerConfig) {
	MapConfig mapConfig = new MapConfig();
	mapConfig.setName("testMap");
	mapConfig.setMaxIdleSeconds(TTL);
	mapConfig.setEntryListenerConfigs(Collections.singletonList(entryListenerConfig));
	return mapConfig;
	}

	private static void insertData(IMap<String, Order> map) {
	for (int i = 0; i < 100; i++) {
	map.put(i + "_", new Order());
	}
	System.err.println("finished inserting to map");
	}

	private static class Order implements Serializable {
	public LocalTime localTime;

	public Order() {
	this.localTime = LocalTime.now();
	}
	}

	private static class EvictionListener implements EntryEvictedListener<String, Order> {
	@Override
	public void entryEvicted(EntryEvent<String, Order> event) {
	final LocalTime now = LocalTime.now();
	System.err.println(event.getKey());
	System.err.println("time inserted:\t" + event.getOldValue().localTime);
	System.err.println("time evicted:\t" + now);
	System.err.println("");
	}
	}
	}