X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=tapi%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Ftapi%2Ftopology%2FTapiNetconfTopologyListener.java;h=8a44695f6261c25d7d3621f28e96d096015d1876;hb=b1b3bafd549bb501937cea5c976d5344608b6ed3;hp=b1f33aa618b91e4cd9bc5d6742724307242dc315;hpb=b83c844bfa881465108c190acdcb2e6b226fa8d4;p=transportpce.git diff --git a/tapi/src/main/java/org/opendaylight/transportpce/tapi/topology/TapiNetconfTopologyListener.java b/tapi/src/main/java/org/opendaylight/transportpce/tapi/topology/TapiNetconfTopologyListener.java index b1f33aa61..8a44695f6 100644 --- a/tapi/src/main/java/org/opendaylight/transportpce/tapi/topology/TapiNetconfTopologyListener.java +++ b/tapi/src/main/java/org/opendaylight/transportpce/tapi/topology/TapiNetconfTopologyListener.java @@ -7,15 +7,15 @@ */ package org.opendaylight.transportpce.tapi.topology; -import java.util.Collection; +import java.util.List; import java.util.Optional; import org.opendaylight.mdsal.binding.api.DataObjectModification; import org.opendaylight.mdsal.binding.api.DataTreeChangeListener; import org.opendaylight.mdsal.binding.api.DataTreeModification; import org.opendaylight.transportpce.common.StringConstants; -import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev221225.ConnectionOper.ConnectionStatus; -import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev221225.connection.oper.available.capabilities.AvailableCapability; -import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev221225.NetconfNode; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev240120.ConnectionOper.ConnectionStatus; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.device.rev240120.connection.oper.available.capabilities.AvailableCapability; +import org.opendaylight.yang.gen.v1.urn.opendaylight.netconf.node.topology.rev231121.NetconfNode; import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -30,16 +30,16 @@ public class TapiNetconfTopologyListener implements DataTreeChangeListener } @Override - public void onDataTreeChanged(Collection> changes) { + public void onDataTreeChanged(List> changes) { LOG.info("onDataTreeChanged - {}", this.getClass().getSimpleName()); for (DataTreeModification change : changes) { DataObjectModification rootNode = change.getRootNode(); - if (rootNode.getDataBefore() == null) { + if (rootNode.dataBefore() == null) { continue; } - String nodeId = rootNode.getDataBefore().key().getNodeId().getValue(); - NetconfNode netconfNodeBefore = rootNode.getDataBefore().augmentation(NetconfNode.class); - switch (rootNode.getModificationType()) { + String nodeId = rootNode.dataBefore().key().getNodeId().getValue(); + NetconfNode netconfNodeBefore = rootNode.dataBefore().augmentation(NetconfNode.class); + switch (rootNode.modificationType()) { case DELETE: this.tapiNetworkModelService.deleteTapinode(nodeId); // TODO -> unregistration to NETCONF stream not yet supported @@ -47,7 +47,7 @@ public class TapiNetconfTopologyListener implements DataTreeChangeListener LOG.info("Device {} correctly disconnected from controller", nodeId); break; case WRITE: - NetconfNode netconfNodeAfter = rootNode.getDataAfter().augmentation(NetconfNode.class); + NetconfNode netconfNodeAfter = rootNode.dataAfter().augmentation(NetconfNode.class); if (ConnectionStatus.Connecting.equals(netconfNodeBefore.getConnectionStatus()) && ConnectionStatus.Connected.equals(netconfNodeAfter.getConnectionStatus())) { LOG.info("Connecting Node: {}", nodeId); @@ -70,7 +70,7 @@ public class TapiNetconfTopologyListener implements DataTreeChangeListener } break; default: - LOG.debug("Unknown modification type {}", rootNode.getModificationType().name()); + LOG.debug("Unknown modification type {}", rootNode.modificationType().name()); break; } }