commit 34fec8414649a0727eeee2c60a4a68ca36d71a24
author Madan Jampani <madan@onlab.us> Wed Jul 22 14:05:08 2015 -0700
committer Madan Jampani <madan@onlab.us> Wed Jul 22 23:40:46 2015 -0700
tree 3b600be730523b70f1066e7938829a12dce7678f
parent 772717567bac3d7936b3370f5c7a8248f3360ae5

Turning on consistent and ordered notification support for multi-partition usecase

Change-Id: I450737bcfd4f1480c60223a84785f35325bf21d2

core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabase.java

diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabase.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabase.java
index aa2d753..cdc904b 100644
--- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabase.java
+++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/PartitionedDatabase.java
@@ -367,14 +367,16 @@
 
     @Override
     public boolean hasChangeNotificationSupport() {
-        return false;
+        return true;
     }
 
     @Override
     public void registerConsumer(Consumer<StateMachineUpdate> consumer) {
+        partitions.forEach(p -> p.registerConsumer(consumer));
     }
 
     @Override
     public void unregisterConsumer(Consumer<StateMachineUpdate> consumer) {
+        partitions.forEach(p -> p.unregisterConsumer(consumer));
     }
 }