Migrate from adsal Node to mdsal Node
[ovsdb.git] / plugin / src / main / java / org / opendaylight / ovsdb / plugin / api / Connection.java
index 1dc1e8f1ee73deb660ea9e5bff3d45daebbf597a..c7091a61106d5764fd91f5acc166b30527033c01 100644 (file)
@@ -9,9 +9,12 @@
  */
 package org.opendaylight.ovsdb.plugin.api;
 
-import org.opendaylight.controller.sal.core.ConstructionException;
-import org.opendaylight.controller.sal.core.Node;
 import org.opendaylight.ovsdb.lib.OvsdbClient;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeBuilder;
+import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.NodeKey;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -33,17 +36,17 @@ public class Connection {
     private static final Logger logger = LoggerFactory.getLogger(Connection.class);
 
     public Connection(String identifier, OvsdbClient client) {
-
         super();
 
         this.identifier = identifier;
         this.client = client;
         this.idCounter = 0L;
-        try {
-            node = new Node("OVS", identifier);
-        } catch (ConstructionException e) {
-            logger.error("Error creating OVS node with identifier " + identifier, e);
-        }
+        NodeId nodeId = new NodeId("OVS" + "|" + identifier);
+        NodeKey nodeKey = new NodeKey(nodeId);
+        node = new NodeBuilder()
+                .setId(nodeId)
+                .setKey(nodeKey)
+                .build();
     }
 
     public String getIdentifier() {