package com.test;

import java.util.Date;
import java.util.concurrent.TimeUnit;

import com.hazelcast.client.HazelcastClient;
import com.hazelcast.client.config.ClientConfig;
import com.hazelcast.client.config.ClientNetworkConfig;
import com.hazelcast.config.SSLConfig;
import com.hazelcast.core.EntryEvent;
import com.hazelcast.core.Hazelcast;
import com.hazelcast.core.HazelcastInstance;
import com.hazelcast.map.IMap;
import com.hazelcast.map.MapEvent;
import com.hazelcast.map.listener.EntryAddedListener;
import com.hazelcast.map.listener.EntryEvictedListener;
import com.hazelcast.map.listener.EntryLoadedListener;
import com.hazelcast.map.listener.EntryRemovedListener;
import com.hazelcast.map.listener.EntryUpdatedListener;
import com.hazelcast.map.listener.MapClearedListener;
import com.hazelcast.map.listener.MapEvictedListener;

public class Listen {

	 public static void main( String[] args ) {
	        HazelcastInstance hz = Hazelcast.newHazelcastInstance();
	        IMap<String, String> map = hz.getMap( "somemap" );
	        map.addEntryListener( new MyEntryListener(), true );
	        System.out.println( new Date()+" EntryListener registered" );
	        
	        long nanotime=System.nanoTime();
	        String key = "" + nanotime;
	        String value = "1";
			map.setTtl(key, 60, TimeUnit.SECONDS);
	        map.put( key, value );
	         
	        ClientConfig clientConfig = new ClientConfig();
	        clientConfig.setProperty("hazelcast.client.max.concurrent.invocations", "5");
	        ClientNetworkConfig networkConfig = clientConfig.getNetworkConfig();
	        networkConfig.setSSLConfig(new SSLConfig().setEnabled(false));
	        networkConfig.addAddress("0.0.0.0", "0.0.0.0");
	        networkConfig.setSmartRouting(true);
	        networkConfig.setConnectionTimeout(10000);
	        networkConfig.setRedoOperation(true);
	        ;

	        com.hazelcast.map.IMap<Object, Object> map1 =  HazelcastClient.newHazelcastClient(clientConfig).getMap("somemap");
	        map1.addEntryListener(new MyEntryListener(), true);	        
	    }

	    static class MyEntryListener implements
	            EntryAddedListener<String, String>,
	            EntryRemovedListener<String, String>,
	            EntryUpdatedListener<String, String>,
	            EntryEvictedListener<String, String>,
	            EntryLoadedListener<String,String>,
	            MapEvictedListener,
	            MapClearedListener   {

			public void mapCleared(MapEvent event) {
				// TODO Auto-generated method stub
				 System.out.println( new Date() + " Map Evicted:" + event );
			}

			public void mapEvicted(MapEvent event) {
				// TODO Auto-generated method stub
				 System.out.println( new Date() + " Map Evicted:" + event );
			}

			public void entryLoaded(EntryEvent<String, String> event) {
				// TODO Auto-generated method stub
				 System.out.println( "Entry Loaded:" + event );
			}

			public void entryEvicted(EntryEvent<String, String> event) {
				// TODO Auto-generated method stub
	            System.out.println( new Date() + " Entry Evicted:" + event );
			}

			public void entryUpdated(EntryEvent<String, String> event) {
				// TODO Auto-generated method stub
				 System.out.println( new Date() + " Entry Updated:" + event );
			}

			public void entryRemoved(EntryEvent<String, String> event) {
				// TODO Auto-generated method stub
	            System.out.println( new Date()+" Entry removed:" + event );
			}

			public void entryAdded(EntryEvent<String, String> event) {
				// TODO Auto-generated method stub
	            System.out.println( new Date()+" Entry Added:" + event );
			}
	    }
	}
=============================================================

EntryListener registered
Wed Nov 02 16:35:15 IST 2022 Entry Added:EntryEvent{entryEventType=ADDED, member=Member [10.126.208.42]:5701 - 5d9123ad-52ee-492d-9101-26dbbb16c208 this, name='somemap', key=1229220800819600, oldValue=null, value=1, mergingValue=null}