super("shard-tx"); //actor name override used for metering. This does not change the "real" actor name
this.shardActor = shardActor;
this.shardStats = shardStats;
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.clientTxVersion = clientTxVersion;
}
this.shardActor = shardActor;
this.shardStats = shardStats;
this.datastoreContext = datastoreContext;
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.txnClientVersion = txnClientVersion;
this.type = type;
}
package org.opendaylight.controller.cluster.datastore.messages;
+import com.google.common.base.Preconditions;
import org.opendaylight.controller.cluster.datastore.DataStoreVersions;
import org.opendaylight.controller.protobuff.messages.transaction.ShardTransactionMessages;
private CreateTransaction(String transactionId, int transactionType, String transactionChainId,
short version) {
- this.transactionId = transactionId;
+ this.transactionId = Preconditions.checkNotNull(transactionId);
this.transactionType = transactionType;
this.transactionChainId = transactionChainId;
this.version = version;
public ForwardedReadyTransaction(String transactionID, short txnClientVersion,
ReadWriteShardDataTreeTransaction transaction, boolean returnSerialized,
boolean doImmediateCommit) {
- this.transactionID = transactionID;
+ this.transactionID = Preconditions.checkNotNull(transactionID);
this.transaction = Preconditions.checkNotNull(transaction);
this.returnSerialized = returnSerialized;
this.txnClientVersion = txnClientVersion;