import com.google.common.base.Throwables;
import com.google.common.collect.ImmutableMap;
-import com.google.common.util.concurrent.CheckedFuture;
import com.google.common.util.concurrent.FluentFuture;
import com.google.common.util.concurrent.FutureCallback;
import com.google.common.util.concurrent.Futures;
domDataReadWriteTransaction.delete(LogicalDatastoreType.OPERATIONAL, YangInstanceIdentifier.EMPTY);
- domDataReadWriteTransaction.submit();
+ domDataReadWriteTransaction.commit();
assertTrue(latch.await(10, TimeUnit.SECONDS));
domDataReadWriteTransaction.merge(LogicalDatastoreType.CONFIGURATION, YangInstanceIdentifier.EMPTY,
mock(NormalizedNode.class));
- domDataReadWriteTransaction.submit();
+ domDataReadWriteTransaction.commit();
assertTrue(latch.await(10, TimeUnit.SECONDS));
LogicalDatastoreType.OPERATIONAL, domStore, LogicalDatastoreType.CONFIGURATION, domStore),
futureExecutor)) {
- CheckedFuture<Void, TransactionCommitFailedException> submit1 =
- dataBroker.newWriteOnlyTransaction().submit();
+ FluentFuture<? extends CommitInfo> submit1 = dataBroker.newWriteOnlyTransaction().commit();
assertNotNull(submit1);
submit1.get();
- CheckedFuture<Void, TransactionCommitFailedException> submit2 =
- dataBroker.newReadWriteTransaction().submit();
+ FluentFuture<? extends CommitInfo> submit2 = dataBroker.newReadWriteTransaction().commit();
assertNotNull(submit2);