import static org.junit.Assert.assertEquals;
import static org.opendaylight.mdsal.binding.util.Datastore.OPERATIONAL;
-import org.junit.Assert;
import org.junit.Test;
import org.opendaylight.mdsal.binding.api.DataBroker;
import org.opendaylight.mdsal.common.api.LogicalDatastoreType;
public class RetryingManagedNewTransactionRunnerTest extends ManagedNewTransactionRunnerImplTest {
@Override
- protected ManagedNewTransactionRunner createManagedNewTransactionRunnerToTest(DataBroker dataBroker) {
+ protected ManagedNewTransactionRunner createManagedNewTransactionRunnerToTest(final DataBroker dataBroker) {
return new RetryingManagedNewTransactionRunner(dataBroker);
}
TopLevelList data = newTestDataObject();
managedNewTransactionRunner.callWithNewWriteOnlyTransactionAndSubmit(OPERATIONAL,
writeTx -> writeTx.put(TEST_PATH, data)).get();
- Assert.assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
+ assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
}
@Override
TopLevelList data = newTestDataObject();
managedNewTransactionRunner.callWithNewReadWriteTransactionAndSubmit(OPERATIONAL,
writeTx -> writeTx.put(TEST_PATH, data)).get();
- Assert.assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
+ assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
}
@Override
writeTx.put(TEST_PATH, data);
return 1;
}).get());
- Assert.assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
+ assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
}
@Test
managedNewTransactionRunner.callWithNewReadWriteTransactionAndSubmit(OPERATIONAL,
tx -> {
tx.put(TEST_PATH, data);
- Assert.assertEquals(data, tx.read(TEST_PATH).get().get());
+ assertEquals(data, tx.read(TEST_PATH).get().get());
}).get();
- Assert.assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
+ assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
}
@Test
public void testApplyWithNewReadWriteTransactionReadFailedException() throws Exception {
testableDataBroker.failReads(2, new ReadFailedException("bada boum bam!"));
TopLevelList data = newTestDataObject();
- Assert.assertEquals(data, managedNewTransactionRunner.applyWithNewReadWriteTransactionAndSubmit(
+ assertEquals(data, managedNewTransactionRunner.applyWithNewReadWriteTransactionAndSubmit(
OPERATIONAL,
tx -> {
tx.put(TEST_PATH, data);
return tx.read(TEST_PATH).get().get();
}).get());
- Assert.assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
+ assertEquals(data, syncRead(LogicalDatastoreType.OPERATIONAL, TEST_PATH));
}
}