X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FDebugThreePhaseCommitCohortTest.java;h=43fbfea6121d0d1b70d809c5d2d70f891984563a;hb=70b924258e6c87219c38bcfefb3781ee3d2e2d02;hp=630e153b2ab32eae17e7ee5c71943928fa458ecf;hpb=86e398bb1e1a60f7516b398a0f27268bf232049d;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DebugThreePhaseCommitCohortTest.java b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DebugThreePhaseCommitCohortTest.java index 630e153b2a..43fbfea612 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DebugThreePhaseCommitCohortTest.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/test/java/org/opendaylight/controller/cluster/datastore/DebugThreePhaseCommitCohortTest.java @@ -21,7 +21,7 @@ import com.google.common.util.concurrent.ListenableFuture; import java.util.ArrayList; import java.util.List; import org.junit.Test; -import org.opendaylight.controller.cluster.datastore.identifiers.TransactionIdentifier; +import org.opendaylight.controller.cluster.access.concepts.TransactionIdentifier; import org.slf4j.Logger; import scala.concurrent.Future; @@ -31,6 +31,8 @@ import scala.concurrent.Future; * @author Thomas Pantelis */ public class DebugThreePhaseCommitCohortTest { + private final TransactionIdentifier transactionId = MockIdentifiers.transactionIdentifier( + DebugThreePhaseCommitCohortTest.class, "mock"); @Test public void test() { @@ -47,9 +49,8 @@ public class DebugThreePhaseCommitCohortTest { List> expCohortFutures = new ArrayList<>(); doReturn(expCohortFutures).when(mockDelegate).getCohortFutures(); - TransactionIdentifier transactionId = TransactionIdentifier.create("1", 1); Throwable debugContext = new RuntimeException("mock"); - DebugThreePhaseCommitCohort cohort = new DebugThreePhaseCommitCohort(transactionId , mockDelegate , debugContext ); + DebugThreePhaseCommitCohort cohort = new DebugThreePhaseCommitCohort(transactionId , mockDelegate , debugContext); Logger mockLogger = mock(Logger.class); cohort.setLogger(mockLogger);