- ThreePhaseCommitCohortProxy proxy = new ThreePhaseCommitCohortProxy(actorContext,
- Collections.<CohortInfo>emptyList(), "txn-1");
-
- verifyCanCommit(proxy.canCommit(), true);
- verifySuccessfulFuture(proxy.preCommit());
- verifySuccessfulFuture(proxy.commit());
- verifyCohortActors();
- }
-
- @Test
- public void testBackwardsCompatibilityWithPreBoron() throws Exception {
- List<CohortInfo> cohorts = Arrays.asList(
- newCohortInfo(new CohortActor.Builder("txn-1").
- expectCanCommit(ThreePhaseCommitCohortMessages.CanCommitTransaction.class,
- CanCommitTransactionReply.yes(DataStoreVersions.LITHIUM_VERSION)).
- expectCommit(ThreePhaseCommitCohortMessages.CommitTransaction.class,
- CommitTransactionReply.instance(DataStoreVersions.LITHIUM_VERSION)),
- DataStoreVersions.LITHIUM_VERSION));
- ThreePhaseCommitCohortProxy proxy = new ThreePhaseCommitCohortProxy(actorContext, cohorts, "txn-1");
+ ThreePhaseCommitCohortProxy proxy = new ThreePhaseCommitCohortProxy(actorUtils,
+ Collections.<CohortInfo>emptyList(), tx);