import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
import org.opendaylight.mdsal.dom.broker.AbstractDOMDataBroker;
import org.opendaylight.mdsal.dom.broker.SerializedDOMDataBroker;
-import org.opendaylight.mdsal.dom.api.DOMDataReadTransaction;
-import org.opendaylight.mdsal.dom.api.DOMDataWriteTransaction;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeReadTransaction;
+import org.opendaylight.mdsal.dom.api.DOMDataTreeWriteTransaction;
import org.opendaylight.mdsal.dom.api.DOMTransactionChain;
import com.google.common.base.Optional;
*
*
*/
- DOMDataWriteTransaction firstTx = allocateAndWrite(txChain);
+ DOMDataTreeWriteTransaction firstTx = allocateAndWrite(txChain);
/**
* First transaction is marked as ready, we are able to allocate chained
/**
* We alocate chained transaction - read transaction.
*/
- DOMDataReadTransaction secondReadTx = txChain.newReadOnlyTransaction();
+ DOMDataTreeReadTransaction secondReadTx = txChain.newReadOnlyTransaction();
/**
*
* is read-write.
*
*/
- DOMDataWriteTransaction thirdDeleteTx = allocateAndDelete(txChain);
+ DOMDataTreeWriteTransaction thirdDeleteTx = allocateAndDelete(txChain);
/**
* We commit first transaction
* Allocates transaction from data store.
*
*/
- DOMDataReadTransaction storeReadTx = domBroker.newReadOnlyTransaction();
+ DOMDataTreeReadTransaction storeReadTx = domBroker.newReadOnlyTransaction();
/**
* We verify transaction is commited to store, container should exists
}
}
- private static DOMDataWriteTransaction allocateAndDelete(final DOMTransactionChain txChain)
+ private static DOMDataTreeWriteTransaction allocateAndDelete(final DOMTransactionChain txChain)
throws InterruptedException, ExecutionException {
- DOMDataWriteTransaction tx = txChain.newWriteOnlyTransaction();
+ DOMDataTreeWriteTransaction tx = txChain.newWriteOnlyTransaction();
/**
* We delete node in third transaction
*/
return tx;
}
- private static DOMDataWriteTransaction allocateAndWrite(final DOMTransactionChain txChain)
+ private static DOMDataTreeWriteTransaction allocateAndWrite(final DOMTransactionChain txChain)
throws InterruptedException, ExecutionException {
- DOMDataWriteTransaction tx = txChain.newWriteOnlyTransaction();
+ DOMDataTreeWriteTransaction tx = txChain.newWriteOnlyTransaction();
writeTestContainer(tx);
return tx;
}
future.get();
}
- private static void assertTestContainerExists(final DOMDataReadTransaction readTx) throws InterruptedException,
+ private static void assertTestContainerExists(final DOMDataTreeReadTransaction readTx) throws InterruptedException,
ExecutionException {
ListenableFuture<Optional<NormalizedNode<?, ?>>> readFuture = readTx.read(OPERATIONAL, TestModel.TEST_PATH);
Optional<NormalizedNode<?, ?>> readedData = readFuture.get();
assertTrue(readedData.isPresent());
}
- private static void writeTestContainer(final DOMDataWriteTransaction tx) throws InterruptedException,
+ private static void writeTestContainer(final DOMDataTreeWriteTransaction tx) throws InterruptedException,
ExecutionException {
tx.put(OPERATIONAL, TestModel.TEST_PATH, ImmutableNodes.containerNode(TestModel.TEST_QNAME));
}