From ae90c8e606d998d4117cb726af6c5516138c4172 Mon Sep 17 00:00:00 2001 From: donnerbart Date: Thu, 20 Oct 2016 01:52:49 +0200 Subject: [PATCH] Fixed CheckStyle issues in Hazelcast Spring Configuration Example module. --- .../HazelcastDataTypes.java | 31 ++++++++++--------- 1 file changed, 17 insertions(+), 14 deletions(-) diff --git a/hazelcast-integration/spring-configuration/src/main/java/com/hazelcast/springconfiguration/HazelcastDataTypes.java b/hazelcast-integration/spring-configuration/src/main/java/com/hazelcast/springconfiguration/HazelcastDataTypes.java index 06948d1a6..d18a1c8ac 100644 --- a/hazelcast-integration/spring-configuration/src/main/java/com/hazelcast/springconfiguration/HazelcastDataTypes.java +++ b/hazelcast-integration/spring-configuration/src/main/java/com/hazelcast/springconfiguration/HazelcastDataTypes.java @@ -24,6 +24,7 @@ import java.io.Serializable; import java.util.Random; +@SuppressWarnings("unchecked") public class HazelcastDataTypes { private static final Random RANDOM = new Random(); @@ -58,7 +59,7 @@ private static void executeMap() { System.out.println("### Map Execution Started... ###"); int key = RANDOM.nextInt(100); int value = RANDOM.nextInt(100); - IMap map = (IMap) context.getBean("map"); + IMap map = (IMap) context.getBean("map", IMap.class); map.put(key, value); System.out.println("A random pair is added to map."); System.out.println("Added value: " + map.get(key) + "\n"); @@ -68,7 +69,7 @@ private static void executeMultiMap() { System.out.println("### MultiMap Execution Started... ###"); int key = RANDOM.nextInt(100); int value = RANDOM.nextInt(100); - MultiMap multimap = (MultiMap) context.getBean("multiMap"); + MultiMap multimap = (MultiMap) context.getBean("multiMap", MultiMap.class); multimap.put(key, value); System.out.println("A random pair is added to multiMap."); System.out.println("Added value: " + multimap.get(key) + "\n"); @@ -78,7 +79,8 @@ private static void executeReplicatedMap() { System.out.println("### ReplicatedMap Execution Started... ###"); int key = RANDOM.nextInt(100); int value = RANDOM.nextInt(100); - ReplicatedMap replicatedMap = (ReplicatedMap) context.getBean("replicatedMap"); + ReplicatedMap replicatedMap = (ReplicatedMap) context + .getBean("replicatedMap", ReplicatedMap.class); replicatedMap.put(key, value); System.out.println("A random pair is added to replicatedMap."); System.out.println("Added value: " + replicatedMap.get(key) + "\n"); @@ -87,7 +89,7 @@ private static void executeReplicatedMap() { private static void executeQueue() { System.out.println("### Queue Execution Started... ###"); int key = RANDOM.nextInt(100); - IQueue queue = (IQueue) context.getBean("queue"); + IQueue queue = (IQueue) context.getBean("queue", IQueue.class); queue.add(key); System.out.println("A random integer is added to queue."); System.out.println("Added element: " + queue.poll() + "\n"); @@ -95,7 +97,7 @@ private static void executeQueue() { private static void executeTopic() { System.out.println("### Topic Execution Started... ###"); - ITopic topic = (ITopic) context.getBean("topic"); + ITopic topic = (ITopic) context.getBean("topic", ITopic.class); topic.addMessageListener(new MessageListener() { @Override public void onMessage(Message message) { @@ -108,7 +110,7 @@ public void onMessage(Message message) { private static void executeSet() { System.out.println("### Set Execution Started... ###"); int key = RANDOM.nextInt(100); - ISet set = (ISet) context.getBean("set"); + ISet set = (ISet) context.getBean("set", ISet.class); set.add(key); System.out.println("A random integer is added to set."); System.out.println("Added element: " + set.iterator().next() + "\n"); @@ -117,7 +119,7 @@ private static void executeSet() { private static void executeList() { System.out.println("### List Execution Started... ###"); int key = RANDOM.nextInt(100); - IList list = (IList) context.getBean("list"); + IList list = (IList) context.getBean("list", IList.class); list.add(key); System.out.println("A random integer is added to list."); System.out.println("Added element: " + list.iterator().next() + "\n"); @@ -125,14 +127,14 @@ private static void executeList() { private static void executeExecutorService() { System.out.println("### ExecutorService Execution Started... ###"); - IExecutorService executorService = (IExecutorService) context.getBean("executorService"); + IExecutorService executorService = context.getBean("executorService", IExecutorService.class); executorService.execute(new EchoTask("hello")); executorService.shutdown(); } private static void executeIdGenerator() { System.out.println("### IdGenerator Execution Started... ###"); - IdGenerator idgenerator = (IdGenerator) context.getBean("idGenerator"); + IdGenerator idgenerator = context.getBean("idGenerator", IdGenerator.class); idgenerator.init(100L); System.out.println("IdGenerator is initialized with 100."); System.out.println("NewId: " + idgenerator.newId() + "\n"); @@ -140,7 +142,7 @@ private static void executeIdGenerator() { private static void executeAtomicLong() { System.out.println("### AtomicLong Execution Started... ###"); - IAtomicLong atomicLong = (IAtomicLong) context.getBean("atomicLong"); + IAtomicLong atomicLong = context.getBean("atomicLong", IAtomicLong.class); atomicLong.set(100L); System.out.println("AtomicLong is set to 100."); System.out.println("AtomicLong: " + atomicLong.get() + "\n"); @@ -148,14 +150,15 @@ private static void executeAtomicLong() { private static void executeAtomicReference() { System.out.println("### AtomicReference Execution Started... ###"); - IAtomicReference atomicReference = (IAtomicReference) context.getBean("atomicReference"); + IAtomicReference atomicReference = (IAtomicReference) context + .getBean("atomicReference", IAtomicReference.class); atomicReference.set("Executing AtomicReference"); System.out.println(atomicReference.get() + "\n"); } private static void executeCountDownLatch() { System.out.println("### CountDownLatch Execution Started... ###"); - ICountDownLatch countDownLatch = (ICountDownLatch) context.getBean("countDownLatch"); + ICountDownLatch countDownLatch = context.getBean("countDownLatch", ICountDownLatch.class); countDownLatch.trySetCount(10); System.out.println("Count is set to 10."); countDownLatch.countDown(); @@ -165,7 +168,7 @@ private static void executeCountDownLatch() { private static void executeSemaphore() { System.out.println("### Semaphore Execution Started... ###"); - ISemaphore semaphore = (ISemaphore) context.getBean("semaphore"); + ISemaphore semaphore = context.getBean("semaphore", ISemaphore.class); semaphore.init(5); System.out.println("Semaphore initialized with 5."); try { @@ -182,7 +185,7 @@ private static void executeSemaphore() { private static void executeLock() { System.out.println("### Lock Execution Started... ###"); - ILock lock = (ILock) context.getBean("lock"); + ILock lock = context.getBean("lock", ILock.class); lock.lock(); System.out.println("lock() call..."); System.out.println("is locked by current thread? :" + lock.isLockedByCurrentThread());