- private final String transactionID;
- private final DOMStoreThreePhaseCommitCohort cohort;
- private final Modification modification;
- private final boolean returnSerialized;
- private final int txnClientVersion;
-
- public ForwardedReadyTransaction(String transactionID, int txnClientVersion,
- DOMStoreThreePhaseCommitCohort cohort, Modification modification,
- boolean returnSerialized) {
- this.transactionID = transactionID;
- this.cohort = cohort;
- this.modification = modification;
- this.returnSerialized = returnSerialized;
+ private final TransactionIdentifier transactionId;
+ private final ReadWriteShardDataTreeTransaction transaction;
+ private final boolean doImmediateCommit;
+ private final short txnClientVersion;
+ @Nullable
+ private final SortedSet<String> participatingShardNames;
+
+ public ForwardedReadyTransaction(TransactionIdentifier transactionId, short txnClientVersion,
+ ReadWriteShardDataTreeTransaction transaction, boolean doImmediateCommit,
+ Optional<SortedSet<String>> participatingShardNames) {
+ this.transactionId = requireNonNull(transactionId);
+ this.transaction = requireNonNull(transaction);