X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=sdclient%2Fdiscovery-service%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fmsb%2Fsdclient%2Fwrapper%2Fconsul%2Fcache%2FHealthCache.java;h=cf4268967ee2cbb58cf28ec9c9c50d230cf37865;hb=2b92d751f640407466da230ac2cec8ffe63981d0;hp=60ba87779c6878f7dc59509118e83b378422fb10;hpb=9fc3ed0bf0a162b5ef97a1ec8185278fd61c9cb2;p=msb%2Fdiscovery.git

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);