@BeforeClass
public static void setUpClass() throws IOException {
system = ActorSystem.create("cluster-test", ConfigFactory.load().getConfig("Member1"));
- final Address member1Address = AddressFromURIString.parse("akka.tcp://cluster-test@127.0.0.1:2558");
+ final Address member1Address = AddressFromURIString.parse("akka://cluster-test@127.0.0.1:2558");
Cluster.get(system).join(member1Address);
}
ArgumentCaptor<DOMDataTreeCandidate> candidateCapt = ArgumentCaptor.forClass(DOMDataTreeCandidate.class);
new IntegrationTestKit(getSystem(), datastoreContextBuilder) {
{
- try (final DistributedDataStore 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 DistributedDataStore 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 DistributedDataStore dataStore =
+ try (AbstractDataStore dataStore =
setupDistributedDataStore("transactionIntegrationTest", "test-1")) {
dataStore.registerCommitCohort(TEST_ID, cohortToAbort);
Thread.sleep(1000); // Registration is asynchronous