Notification support for Consistent datastructures (ConsitentMap and DistributedSet)
Change-Id: If74cdc411c79c42c7643420e6369cf656849bb6a
diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultConsistentMap.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultConsistentMap.java
index b85dfa2..7995d8f 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultConsistentMap.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DefaultConsistentMap.java
@@ -28,10 +28,9 @@
import java.util.function.Predicate;
import java.util.Set;
-import org.onosproject.store.service.AsyncConsistentMap;
import org.onosproject.store.service.ConsistentMap;
import org.onosproject.store.service.ConsistentMapException;
-import org.onosproject.store.service.Serializer;
+import org.onosproject.store.service.MapEventListener;
import org.onosproject.store.service.Versioned;
/**
@@ -45,13 +44,14 @@
private static final int OPERATION_TIMEOUT_MILLIS = 5000;
- private final AsyncConsistentMap<K, V> asyncMap;
+ private final DefaultAsyncConsistentMap<K, V> asyncMap;
- public DefaultConsistentMap(String name,
- Database database,
- Serializer serializer,
- boolean readOnly) {
- asyncMap = new DefaultAsyncConsistentMap<>(name, database, serializer, readOnly);
+ public String name() {
+ return asyncMap.name();
+ }
+
+ public DefaultConsistentMap(DefaultAsyncConsistentMap<K, V> asyncMap) {
+ this.asyncMap = asyncMap;
}
@Override
@@ -190,4 +190,14 @@
}
}
}
+
+ @Override
+ public void addListener(MapEventListener<K, V> listener) {
+ asyncMap.addListener(listener);
+ }
+
+ @Override
+ public void removeListener(MapEventListener<K, V> listener) {
+ asyncMap.addListener(listener);
+ }
}
\ No newline at end of file