ArgumentCaptor<DOMDataTreeCandidate> candidateCapt = ArgumentCaptor.forClass(DOMDataTreeCandidate.class);
new IntegrationTestKit(getSystem(), datastoreContextBuilder) {
{
- try (final AbstractDataStore dataStore = setupDistributedDataStore("transactionIntegrationTest",
+ try (AbstractDataStore dataStore = setupDistributedDataStore("transactionIntegrationTest",
"test-1")) {
final ObjectRegistration<DOMDataTreeCommitCohort> cohortReg =
dataStore.registerCommitCohort(TEST_ID, cohort);
new IntegrationTestKit(getSystem(), datastoreContextBuilder) {
{
- try (final AbstractDataStore dataStore =
+ try (AbstractDataStore dataStore =
setupDistributedDataStore("transactionIntegrationTest", "test-1")) {
dataStore.registerCommitCohort(TEST_ID, failedCohort);
Thread.sleep(1000); // Registration is asynchronous
Mockito.doReturn(ThreePhaseCommitStep.NOOP_ABORT_FUTURE).when(stepToAbort).abort();
new IntegrationTestKit(getSystem(), datastoreContextBuilder) {
{
- try (final AbstractDataStore dataStore =
+ try (AbstractDataStore dataStore =
setupDistributedDataStore("transactionIntegrationTest", "test-1")) {
dataStore.registerCommitCohort(TEST_ID, cohortToAbort);
Thread.sleep(1000); // Registration is asynchronous