+ }
+
+ /**
+ * @param iiToNodeInInventory
+ * @param addedData
+ */
+ private void createNewNodeInTopology(InstanceIdentifier<?> iiToNodeInInventory, final FlowCapableNode addedData) {
+ final NodeBuilder topologyNodeBuilder = new NodeBuilder();
+ final NodeKey inventoryNodeKey = iiToNodeInInventory.firstKeyOf(Node.class, NodeKey.class);
+ if (inventoryNodeKey != null) {
+ NodeId nodeIdInTopology = new NodeId(inventoryNodeKey.getId().getValue());
+ org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey nodeKeyInTopology = new org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.NodeKey(nodeIdInTopology);
+ topologyNodeBuilder.setNodeId(nodeIdInTopology);
+
+ final InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node> iiToTopologyNode = II_TO_TOPOLOGY
+ .builder()
+ .child(org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.Node.class, nodeKeyInTopology)
+ .build();
+
+ operationProcessor.enqueueOperation(new TopologyOperation() {
+
+ @Override
+ public void applyOperation(ReadWriteTransaction transaction) {
+ transaction.put(LogicalDatastoreType.OPERATIONAL, iiToTopologyNode, topologyNodeBuilder.build());
+ }
+ });
+ } else {
+ LOG.debug("Inventory node key is null. Data can't be written to topology");