- private final String transactionID;
- private final DOMStoreThreePhaseCommitCohort cohort;
- private final Modification modification;
-
- public ForwardedReadyTransaction(String transactionID, DOMStoreThreePhaseCommitCohort cohort,
- Modification modification) {
- this.transactionID = transactionID;
- this.cohort = cohort;
- this.modification = modification;
+ private final TransactionIdentifier transactionId;
+ private final ReadWriteShardDataTreeTransaction transaction;
+ private final boolean doImmediateCommit;
+ private final short txnClientVersion;
+
+ public ForwardedReadyTransaction(TransactionIdentifier transactionId, short txnClientVersion,
+ ReadWriteShardDataTreeTransaction transaction, boolean doImmediateCommit) {
+ this.transactionId = Preconditions.checkNotNull(transactionId);
+ this.transaction = Preconditions.checkNotNull(transaction);
+ this.txnClientVersion = txnClientVersion;
+ this.doImmediateCommit = doImmediateCommit;
+ }
+
+ public TransactionIdentifier getTransactionId() {
+ return transactionId;
+ }
+
+ public ReadWriteShardDataTreeTransaction getTransaction() {
+ return transaction;