- private static DOMDataReadWriteTransaction allocateAndWrite(
- final DOMTransactionChain txChain) throws InterruptedException, ExecutionException {
+ private static DOMDataReadWriteTransaction allocateAndWrite(final DOMTransactionChain txChain)
+ throws InterruptedException, ExecutionException {
- private static void assertCommitSuccessful(
- final ListenableFuture<Void> future) throws InterruptedException, ExecutionException {
+ private static void assertCommitSuccessful(final ListenableFuture<?> future)
+ throws InterruptedException, ExecutionException {
- private static void assertTestContainerExists(
- final DOMDataReadTransaction readTx) throws InterruptedException, ExecutionException {
+ private static void assertTestContainerExists(final DOMDataReadTransaction readTx)
+ throws InterruptedException, ExecutionException {
ListenableFuture<Optional<NormalizedNode<?, ?>>> readFuture = readTx.read(OPERATIONAL, TestModel.TEST_PATH);
Optional<NormalizedNode<?, ?>> readedData = readFuture.get();
assertTrue(readedData.isPresent());
}
ListenableFuture<Optional<NormalizedNode<?, ?>>> readFuture = readTx.read(OPERATIONAL, TestModel.TEST_PATH);
Optional<NormalizedNode<?, ?>> readedData = readFuture.get();
assertTrue(readedData.isPresent());
}
- private static void assertTestContainerWrite(
- final DOMDataReadWriteTransaction tx) throws InterruptedException, ExecutionException {
+ private static void assertTestContainerWrite(final DOMDataReadWriteTransaction tx)
+ throws InterruptedException, ExecutionException {
tx.put(OPERATIONAL, TestModel.TEST_PATH, ImmutableNodes.containerNode(TestModel.TEST_QNAME));
assertTestContainerExists(tx);
}
tx.put(OPERATIONAL, TestModel.TEST_PATH, ImmutableNodes.containerNode(TestModel.TEST_QNAME));
assertTestContainerExists(tx);
}