AsyncConsistentMap methods for supporting transactional updates
Change-Id: Iaeb0aa0abf9f52d514a2c040598599a5b8a55ee8
diff --git a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java
index a5dd232..458e5fb 100644
--- a/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java
+++ b/core/store/primitives/src/main/java/org/onosproject/store/primitives/resources/impl/AtomixConsistentMapCommands.java
@@ -29,7 +29,7 @@
import org.onlab.util.Match;
import org.onosproject.store.primitives.TransactionId;
-import org.onosproject.store.primitives.impl.Transaction;
+import org.onosproject.store.service.MapTransaction;
import org.onosproject.store.service.Versioned;
import com.google.common.base.MoreObjects;
@@ -209,35 +209,35 @@
*/
@SuppressWarnings("serial")
public static class TransactionPrepare extends MapCommand<PrepareResult> {
- private Transaction transaction;
+ private MapTransaction<String, byte[]> mapTransaction;
public TransactionPrepare() {
}
- public TransactionPrepare(Transaction transaction) {
- this.transaction = transaction;
+ public TransactionPrepare(MapTransaction<String, byte[]> mapTransaction) {
+ this.mapTransaction = mapTransaction;
}
- public Transaction transaction() {
- return transaction;
+ public MapTransaction<String, byte[]> transaction() {
+ return mapTransaction;
}
@Override
public void writeObject(BufferOutput<?> buffer, Serializer serializer) {
super.writeObject(buffer, serializer);
- serializer.writeObject(transaction, buffer);
+ serializer.writeObject(mapTransaction, buffer);
}
@Override
public void readObject(BufferInput<?> buffer, Serializer serializer) {
super.readObject(buffer, serializer);
- transaction = serializer.readObject(buffer);
+ mapTransaction = serializer.readObject(buffer);
}
@Override
public String toString() {
return MoreObjects.toStringHelper(getClass())
- .add("transaction", transaction)
+ .add("mapTransaction", mapTransaction)
.toString();
}
}