Fixup Augmentable and Identifiable methods changing

[netconf.git] / netconf / netconf-notifications-impl / src / main / java / org / opendaylight / netconf / notifications / impl / NetconfNotificationManager.java

diff --git a/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/NetconfNotificationManager.java b/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/NetconfNotificationManager.java
index c8989e59496ae304ccbf721f75c4e3d3c3023c29..ac29d547444c8f321be54deecb38de42c78678b5 100644 (file)
--- a/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/NetconfNotificationManager.java
+++ b/netconf/netconf-notifications-impl/src/main/java/org/opendaylight/netconf/notifications/impl/NetconfNotificationManager.java
@@ -53,7 +53,7 @@ public class NetconfNotificationManager implements NetconfNotificationCollector,
     static {
         BASE_NETCONF_STREAM = new StreamBuilder()
                 .setName(BASE_STREAM_NAME)
-                .setKey(new StreamKey(BASE_STREAM_NAME))
+                .withKey(new StreamKey(BASE_STREAM_NAME))
                 .setReplaySupport(false)
                 .setDescription("Default Event Stream")
                 .build();
@@ -138,12 +138,9 @@ public class NetconfNotificationManager implements NetconfNotificationCollector,
             listener.onStreamRegistered(availableStream);
         }
 
-        return new NotificationRegistration() {
-            @Override
-            public void close() {
-                synchronized (NetconfNotificationManager.this) {
-                    streamListeners.remove(listener);
-                }
+        return () -> {
+            synchronized (NetconfNotificationManager.this) {
+                streamListeners.remove(listener);
             }
         };
     }
@@ -277,7 +274,8 @@ public class NetconfNotificationManager implements NetconfNotificationCollector,
             baseRegistration.close();
         }
 
-        private static NetconfNotification serializeNotification(final Notification notification, SchemaPath path) {
+        private static NetconfNotification serializeNotification(final Notification notification,
+                final SchemaPath path) {
             return NotificationsTransformUtil.transform(notification, path);
         }
 
@@ -288,12 +286,12 @@ public class NetconfNotificationManager implements NetconfNotificationCollector,
         }
 
         @Override
-        public void onSessionStarted(NetconfSessionStart start) {
+        public void onSessionStarted(final NetconfSessionStart start) {
             baseRegistration.onNotification(BASE_STREAM_NAME, serializeNotification(start, SESSION_START_PATH));
         }
 
         @Override
-        public void onSessionEnded(NetconfSessionEnd end) {
+        public void onSessionEnded(final NetconfSessionEnd end) {
             baseRegistration.onNotification(BASE_STREAM_NAME, serializeNotification(end, SESSION_END_PATH));
         }
     }