ONOS-1362: Support async version of ConsistentMap that lets efficient chaining of operations
Change-Id: I672a15ba2a517db3e22f6ce8d739ca48307e6e63
diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseManager.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseManager.java
index b78f3ae..6ddeea9 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseManager.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseManager.java
@@ -32,6 +32,7 @@
import org.apache.felix.scr.annotations.Service;
import org.onosproject.cluster.ClusterService;
import org.onosproject.store.cluster.impl.NodeInfo;
+import org.onosproject.store.service.AsyncConsistentMap;
import org.onosproject.store.service.ConsistentMap;
import org.onosproject.store.service.PartitionInfo;
import org.onosproject.store.service.Serializer;
@@ -168,7 +169,12 @@
@Override
public <K, V> ConsistentMap<K , V> createConsistentMap(String name, Serializer serializer) {
- return new ConsistentMapImpl<K, V>(name, partitionedDatabase, serializer);
+ return new DefaultConsistentMap<K, V>(name, partitionedDatabase, serializer);
+ }
+
+ @Override
+ public <K, V> AsyncConsistentMap<K , V> createAsyncConsistentMap(String name, Serializer serializer) {
+ return new DefaultAsyncConsistentMap<K, V>(name, partitionedDatabase, serializer);
}
@Override