Bump upstream dependencies to Ca
[transportpce.git] / networkmodel / src / main / java / org / opendaylight / transportpce / networkmodel / listeners / LldpListener.java
index 276ca0e727440dc91b2cf751d6e4543d4e68a507..e3b08e560980d1970cf82aac68f3f375a2352ae6 100644 (file)
@@ -8,22 +8,19 @@
 
 package org.opendaylight.transportpce.networkmodel.listeners;
 
-import org.opendaylight.transportpce.networkmodel.R2RLinkDiscovery;
+import org.eclipse.jdt.annotation.NonNull;
+import org.opendaylight.mdsal.binding.api.NotificationService.Listener;
 import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev161014.LldpNbrInfoChange;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.lldp.rev161014.OrgOpenroadmLldpListener;
-import org.opendaylight.yang.gen.v1.http.org.openroadm.resource.types.rev161014.ResourceNotificationType;
-import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev150608.NodeId;
+import org.opendaylight.yang.gen.v1.urn.ietf.params.xml.ns.yang.ietf.network.rev180226.NodeId;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class LldpListener implements OrgOpenroadmLldpListener {
+public class LldpListener implements Listener<LldpNbrInfoChange> {
 
     private static final Logger LOG = LoggerFactory.getLogger(LldpListener.class);
-    private final R2RLinkDiscovery linkDiscovery;
     private final NodeId nodeId;
 
-    public LldpListener(final R2RLinkDiscovery linkDiscovery, final String nodeId) {
-        this.linkDiscovery = linkDiscovery;
+    public LldpListener(final String nodeId) {
         this.nodeId = new NodeId(nodeId);
     }
 
@@ -32,16 +29,7 @@ public class LldpListener implements OrgOpenroadmLldpListener {
      * @param notification LldpNbrInfoChange object
      */
     @Override
-    public void onLldpNbrInfoChange(LldpNbrInfoChange notification) {
-        LOG.info("Notification {} received {}", LldpNbrInfoChange.QNAME, notification);
-        if (notification.getNotificationType().equals(ResourceNotificationType.ResourceCreation)) {
-            linkDiscovery.createR2RLink(nodeId,notification.getResource(),
-                                                notification.getNbrInfo().getRemoteSysName(),
-                                                notification.getNbrInfo().getRemotePortId());
-        } else if (notification.getNotificationType().equals(ResourceNotificationType.ResourceDeletion)) {
-            linkDiscovery.deleteR2RLink(nodeId,notification.getResource(),
-                                                notification.getNbrInfo().getRemoteSysName(),
-                                                notification.getNbrInfo().getRemotePortId());
-        }
+    public void onNotification(@NonNull LldpNbrInfoChange notification) {
+        LOG.info("Notification {} received {} on node {}", LldpNbrInfoChange.QNAME, notification, nodeId);
     }
 }