diff --git a/libraries/src/main/java/com/baeldung/infinispan/CacheConfiguration.java b/libraries/src/main/java/com/baeldung/infinispan/CacheConfiguration.java index bf214458f3..58929c0111 100644 --- a/libraries/src/main/java/com/baeldung/infinispan/CacheConfiguration.java +++ b/libraries/src/main/java/com/baeldung/infinispan/CacheConfiguration.java @@ -20,8 +20,7 @@ public class CacheConfiguration { public static final String TRANSACTIONAL_CACHE = "transactional-cache"; public DefaultCacheManager cacheManager() { - DefaultCacheManager cacheManager = new DefaultCacheManager(); - return cacheManager; + return new DefaultCacheManager(); } public Cache transactionalCache(DefaultCacheManager cacheManager, CacheListener listener) { diff --git a/libraries/src/main/java/com/baeldung/infinispan/listener/CacheListener.java b/libraries/src/main/java/com/baeldung/infinispan/listener/CacheListener.java index 2f6536ad87..942a2fb62d 100644 --- a/libraries/src/main/java/com/baeldung/infinispan/listener/CacheListener.java +++ b/libraries/src/main/java/com/baeldung/infinispan/listener/CacheListener.java @@ -40,9 +40,7 @@ public class CacheListener { @CacheEntriesEvicted public void entriesEvicted(CacheEntriesEvictedEvent event) { final StringBuilder builder = new StringBuilder(); - event.getEntries().entrySet().forEach((e) -> - builder.append(e.getKey() + ", ") - ); + event.getEntries().forEach((key, value) -> builder.append(key).append(", ")); System.out.println("Evicting following entries from cache: " + builder.toString()); } diff --git a/libraries/src/main/java/com/baeldung/infinispan/service/HelloWorldService.java b/libraries/src/main/java/com/baeldung/infinispan/service/HelloWorldService.java index 0d1ffb4168..3ecefcc21a 100644 --- a/libraries/src/main/java/com/baeldung/infinispan/service/HelloWorldService.java +++ b/libraries/src/main/java/com/baeldung/infinispan/service/HelloWorldService.java @@ -31,12 +31,7 @@ public class HelloWorldService { public String findSimpleHelloWorld() { String cacheKey = "simple-hello"; - String helloWorld = simpleHelloWorldCache.get(cacheKey); - if (helloWorld == null) { - helloWorld = repository.getHelloWorld(); - simpleHelloWorldCache.put(cacheKey, helloWorld); - } - return helloWorld; + return simpleHelloWorldCache.computeIfAbsent(cacheKey, k -> repository.getHelloWorld()); } public String findExpiringHelloWorld() { @@ -79,12 +74,7 @@ public class HelloWorldService { } public String findPassivatingHelloWorld(String key) { - String value = passivatingHelloWorldCache.get(key); - if(value == null) { - value = repository.getHelloWorld(); - passivatingHelloWorldCache.put(key, value); - } - return value; + return passivatingHelloWorldCache.computeIfAbsent(key, k -> repository.getHelloWorld()); } } diff --git a/libraries/src/test/java/com/baeldung/infinispan/ConfigurationTest.java b/libraries/src/test/java/com/baeldung/infinispan/ConfigurationTest.java index 906a887e1a..c9ebe77679 100644 --- a/libraries/src/test/java/com/baeldung/infinispan/ConfigurationTest.java +++ b/libraries/src/test/java/com/baeldung/infinispan/ConfigurationTest.java @@ -9,7 +9,7 @@ import org.infinispan.manager.DefaultCacheManager; import org.junit.After; import org.junit.Before; -import java.util.concurrent.Callable; +import java.util.function.Supplier; public class ConfigurationTest { @@ -47,7 +47,6 @@ public class ConfigurationTest { passivatingHelloWorldCache); this.transactionalService = new TransactionalService(transactionalCache); - } @After @@ -55,15 +54,9 @@ public class ConfigurationTest { cacheManager.stop(); } - protected long timeThis(Callable callable) { - try { - long milis = System.currentTimeMillis(); - callable.call(); - return System.currentTimeMillis() - milis; - } catch (Exception e) { - e.printStackTrace(); - } - return 0l; + protected long timeThis(Supplier supplier) { + long millis = System.currentTimeMillis(); + supplier.get(); + return System.currentTimeMillis() - millis; } - }