HONEYCOMB-61: Detect VPP disconnect using keepalives

Change-Id: Ic664dbf452504d0fff97e8c766d735d9c5d95c72
Signed-off-by: Maros Marsalek <mmarsale@cisco.com>

1 files changed, 2 insertions, 9 deletions

diff --git a/v3po/translate-utils/src/main/java/io/fd/honeycomb/v3po/translate/util/write/DelegatingWriterRegistry.java b/v3po/translate-utils/src/main/java/io/fd/honeycomb/v3po/translate/util/write/DelegatingWriterRegistry.java
index 7eba98a07..8b981af0d 100644
--- a/v3po/translate-utils/src/main/java/io/fd/honeycomb/v3po/translate/util/write/DelegatingWriterRegistry.java
+++ b/v3po/translate-utils/src/main/java/io/fd/honeycomb/v3po/translate/util/write/DelegatingWriterRegistry.java
@@ -50,14 +50,6 @@ public final class DelegatingWriterRegistry implements WriterRegistry {
 
     private static final Logger LOG = LoggerFactory.getLogger(DelegatingWriterRegistry.class);
 
-    private static final Function<InstanceIdentifier<?>, Class<? extends DataObject>> ID_TO_CLASS =
-            new Function<InstanceIdentifier<?>, Class<? extends DataObject>>() {
-                @Override
-                public Class<? extends DataObject> apply(final InstanceIdentifier<?> input) {
-                    return input.getTargetType();
-                }
-            };
-
     private final Map<Class<? extends DataObject>, Writer<? extends DataObject>> rootWriters;
 
     /**
@@ -130,7 +122,8 @@ public final class DelegatingWriterRegistry implements WriterRegistry {
 
     private void checkAllWritersPresent(final @Nonnull Map<InstanceIdentifier<?>, DataObject> nodesBefore) {
         final Set<Class<? extends DataObject>> nodesBeforeClasses =
-            Sets.newHashSet(Collections2.transform(nodesBefore.keySet(), ID_TO_CLASS));
+            Sets.newHashSet(Collections2.transform(nodesBefore.keySet(),
+                (Function<InstanceIdentifier<?>, Class<? extends DataObject>>) InstanceIdentifier::getTargetType));
         checkArgument(rootWriters.keySet().containsAll(nodesBeforeClasses),
                 "Unable to handle all changes. Missing dedicated writers for: %s",
                 Sets.difference(nodesBeforeClasses, rootWriters.keySet()));