import java.util.ArrayList;
import java.util.LinkedList;
import java.util.List;
+import java.util.Optional;
+import java.util.concurrent.ExecutionException;
-import org.opendaylight.controller.md.sal.binding.api.DataBroker;
-import org.opendaylight.controller.md.sal.binding.api.ReadWriteTransaction;
-import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType;
-import org.opendaylight.controller.md.sal.common.api.data.ReadFailedException;
+import org.opendaylight.mdsal.binding.api.DataBroker;
+import org.opendaylight.mdsal.binding.api.ReadWriteTransaction;
+import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.unimgr.mef.nrp.impl.NrpInitializer;
import org.opendaylight.unimgr.mef.nrp.ovs.DataStoreTestUtils;
import org.opendaylight.unimgr.mef.nrp.ovs.OpenFlowTopologyTestUtils;
import org.opendaylight.yang.gen.v1.urn.tbd.params.xml.ns.yang.network.topology.rev131021.network.topology.topology.node.TerminationPoint;
import org.opendaylight.yangtools.yang.binding.InstanceIdentifier;
-import com.google.common.base.Optional;
/**
* @author marek.ryznar@amartus.com
ReadWriteTransaction transaction = dataBroker.newReadWriteTransaction();
transaction.put(LogicalDatastoreType.OPERATIONAL,nodesIId,nodes);
- transaction.submit();
+ transaction.commit();
}
private org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node createOpenFlowNode(String oFName) {
protected List<org.opendaylight.yang.gen.v1.urn.onf.otcc.yang.tapi.common.rev180307.tapi.context.ServiceInterfacePoint> readSips() {
ReadWriteTransaction readWriteTransaction = dataBroker.newReadWriteTransaction();
try {
- Optional<Context> opt = readWriteTransaction.read(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(Context.class)).checkedGet();
+ Optional<Context> opt = readWriteTransaction.read(LogicalDatastoreType.OPERATIONAL, InstanceIdentifier.create(Context.class)).get();
if (opt.isPresent()) {
return opt.get().getServiceInterfacePoint();
} else {
fail("There are no sips.");
}
- } catch (ReadFailedException e) {
+ } catch (InterruptedException | ExecutionException e) {
fail(e.getMessage());
}
return null;