*/
package org.opendaylight.controller.cluster.datastore.messages;
-import org.opendaylight.controller.cluster.datastore.ShardDataTreeCohort;
+import com.google.common.base.Preconditions;
+import org.opendaylight.controller.cluster.datastore.ReadWriteShardDataTreeTransaction;
/**
* Transaction ReadyTransaction message that is forwarded to the local Shard from the ShardTransaction.
*/
public class ForwardedReadyTransaction {
private final String transactionID;
- private final ShardDataTreeCohort cohort;
+ private final ReadWriteShardDataTreeTransaction transaction;
private final boolean returnSerialized;
private final boolean doImmediateCommit;
private final short txnClientVersion;
public ForwardedReadyTransaction(String transactionID, short txnClientVersion,
- ShardDataTreeCohort cohort, boolean returnSerialized,
+ ReadWriteShardDataTreeTransaction transaction, boolean returnSerialized,
boolean doImmediateCommit) {
this.transactionID = transactionID;
- this.cohort = cohort;
+ this.transaction = Preconditions.checkNotNull(transaction);
this.returnSerialized = returnSerialized;
this.txnClientVersion = txnClientVersion;
this.doImmediateCommit = doImmediateCommit;
return transactionID;
}
- public ShardDataTreeCohort getCohort() {
- return cohort;
+ public ReadWriteShardDataTreeTransaction getTransaction() {
+ return transaction;
}
public boolean isReturnSerialized() {