From 97d0c7144961367887dfb7cb1bc54e062002d851 Mon Sep 17 00:00:00 2001 From: Prashant Khanal Date: Tue, 11 Oct 2016 16:06:10 -0700 Subject: [PATCH] Code cleanup Signed-off-by: nguyenminhtuanfit@gmail.com --- .../hazelcast/cluster/NativeClient.java | 12 +++--- .../hazelcast/cluster/ServerNode.java | 9 +--- .../listener/CountryEntryListener.java | 41 ------------------- 3 files changed, 7 insertions(+), 55 deletions(-) delete mode 100644 hazelcast/src/main/java/com/baeldung/hazelcast/listener/CountryEntryListener.java diff --git a/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/NativeClient.java b/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/NativeClient.java index bda4b94733..697e362289 100644 --- a/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/NativeClient.java +++ b/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/NativeClient.java @@ -1,9 +1,7 @@ package com.baeldung.hazelcast.cluster; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; +import java.util.Map.Entry; -import com.baeldung.hazelcast.listener.CountryEntryListener; import com.hazelcast.client.HazelcastClient; import com.hazelcast.client.config.ClientConfig; import com.hazelcast.config.GroupConfig; @@ -11,7 +9,6 @@ import com.hazelcast.core.HazelcastInstance; import com.hazelcast.core.IMap; public class NativeClient { - private static final Logger logger = LoggerFactory.getLogger(NativeClient.class); public static void main(String[] args) throws InterruptedException { ClientConfig config = new ClientConfig(); @@ -19,8 +16,9 @@ public class NativeClient { groupConfig.setName("dev"); groupConfig.setPassword("dev-pass"); HazelcastInstance hazelcastInstanceClient = HazelcastClient.newHazelcastClient(config); - IMap countryMap = hazelcastInstanceClient.getMap("country"); - countryMap.addEntryListener(new CountryEntryListener(), true); - logger.info("Country map size: " + countryMap.size()); + IMap map = hazelcastInstanceClient.getMap("data"); + for (Entry entry : map.entrySet()) { + System.out.println(String.format("Key: %d, Value: %s", entry.getKey(), entry.getValue())); + } } } diff --git a/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/ServerNode.java b/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/ServerNode.java index 01043cf712..36028834a4 100644 --- a/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/ServerNode.java +++ b/hazelcast/src/main/java/com/baeldung/hazelcast/cluster/ServerNode.java @@ -2,23 +2,18 @@ package com.baeldung.hazelcast.cluster; import java.util.Map; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import com.hazelcast.core.Hazelcast; import com.hazelcast.core.HazelcastInstance; import com.hazelcast.core.IdGenerator; public class ServerNode { - private static final Logger logger = LoggerFactory.getLogger(ServerNode.class); public static void main(String[] args) { HazelcastInstance hazelcastInstance = Hazelcast.newHazelcastInstance(); - Map countryMap = hazelcastInstance.getMap("country"); + Map map = hazelcastInstance.getMap("data"); IdGenerator idGenerator = hazelcastInstance.getIdGenerator("newid"); for (int i = 0; i < 10; i++) { - countryMap.put(idGenerator.newId(), "message" + 1); + map.put(idGenerator.newId(), "message" + 1); } - logger.info("Country map size: " + countryMap.size()); } } diff --git a/hazelcast/src/main/java/com/baeldung/hazelcast/listener/CountryEntryListener.java b/hazelcast/src/main/java/com/baeldung/hazelcast/listener/CountryEntryListener.java deleted file mode 100644 index 1f95dcd9f3..0000000000 --- a/hazelcast/src/main/java/com/baeldung/hazelcast/listener/CountryEntryListener.java +++ /dev/null @@ -1,41 +0,0 @@ -package com.baeldung.hazelcast.listener; - -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.hazelcast.core.EntryEvent; -import com.hazelcast.core.MapEvent; -import com.hazelcast.map.listener.EntryAddedListener; -import com.hazelcast.map.listener.EntryEvictedListener; -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 CountryEntryListener implements EntryAddedListener, EntryRemovedListener, EntryUpdatedListener, EntryEvictedListener, MapEvictedListener, MapClearedListener { - private static final Logger logger = LoggerFactory.getLogger(CountryEntryListener.class); - - public void entryAdded(EntryEvent event) { - logger.info("entryAdded:" + event); - } - - public void entryUpdated(EntryEvent event) { - logger.info("entryUpdated:" + event); - } - - public void entryRemoved(EntryEvent event) { - logger.info("entryRemoved:" + event); - } - - public void entryEvicted(EntryEvent event) { - logger.info("entryEvicted:" + event); - } - - public void mapCleared(MapEvent event) { - logger.info("mapCleared:" + event); - } - - public void mapEvicted(MapEvent event) { - logger.info("mapEvicted:" + event); - } -}