1 files changed, 4 insertions, 12 deletions
diff --git a/sdclient/discovery-service/src/main/java/org/onap/msb/sdclient/wrapper/consul/cache/HealthCache.java b/sdclient/discovery-service/src/main/java/org/onap/msb/sdclient/wrapper/consul/cache/HealthCache.java
index 60ba877..cf42689 100644
--- a/sdclient/discovery-service/src/main/java/org/onap/msb/sdclient/wrapper/consul/cache/HealthCache.java
+++ b/sdclient/discovery-service/src/main/java/org/onap/msb/sdclient/wrapper/consul/cache/HealthCache.java
@@ -36,20 +36,12 @@ public class HealthCache extends ConsulCache<String, ServiceHealth> {
 
     public static HealthCache newCache(final HealthClient healthClient, final String serviceName,
                     final int watchSeconds) {
-        Function<ServiceHealth, String> keyExtractor = new Function<ServiceHealth, String>() {
-            @Override
-            public String apply(ServiceHealth input) {
-                // return input.getKey().substring(rootPath.length() + 1);
-                return input.getService().getId();
-            }
+        Function<ServiceHealth, String> keyExtractor = input -> {
+            // return input.getKey().substring(rootPath.length() + 1);
+            return input.getService().getId();
         };
 
-        final CallbackConsumer<ServiceHealth> callbackConsumer = new CallbackConsumer<ServiceHealth>() {
-            @Override
-            public void consume(BigInteger index, ConsulResponseCallback<List<ServiceHealth>> callback) {
-                healthClient.getHealthyServiceInstances(serviceName, watchParams(index, watchSeconds), callback);
-            }
-        };
+        final CallbackConsumer<ServiceHealth> callbackConsumer = (index, callback) -> healthClient.getHealthyServiceInstances(serviceName, watchParams(index, watchSeconds), callback);
 
 
         return new HealthCache(keyExtractor, callbackConsumer, serviceName);