fix serializer in DistributedMcastStore.
Change-Id: I06935b450387da3dea3e2aa65af66e893a9a59a7
diff --git a/incubator/store/src/main/java/org/onosproject/incubator/store/mcast/impl/DistributedMcastStore.java b/incubator/store/src/main/java/org/onosproject/incubator/store/mcast/impl/DistributedMcastStore.java
index 2ad34d8..6379be6 100644
--- a/incubator/store/src/main/java/org/onosproject/incubator/store/mcast/impl/DistributedMcastStore.java
+++ b/incubator/store/src/main/java/org/onosproject/incubator/store/mcast/impl/DistributedMcastStore.java
@@ -6,7 +6,7 @@
import org.apache.felix.scr.annotations.Reference;
import org.apache.felix.scr.annotations.ReferenceCardinality;
import org.apache.felix.scr.annotations.Service;
-import org.onlab.packet.IpPrefix;
+import org.onlab.packet.IpAddress;
import org.onlab.util.KryoNamespace;
import org.onosproject.net.ConnectPoint;
import org.onosproject.net.mcast.McastEvent;
@@ -35,9 +35,9 @@
public class DistributedMcastStore extends AbstractStore<McastEvent, McastStoreDelegate>
implements McastStore {
//FIXME the number of events that will potentially be generated here is
- // not sustainable, consider changing this to an eventually consistent
- // map and not emitting events but rather use a provider-like mechanism
- // to program the dataplane.
+ // not sustainable, consider changing this to an eventually consistent
+ // map and not emitting events but rather use a provider-like mechanism
+ // to program the dataplane.
private static final String MCASTRIB = "mcast-rib-table";
private Logger log = getLogger(getClass());
@@ -58,7 +58,7 @@
MulticastData.class,
McastRoute.class,
McastRoute.Type.class,
- IpPrefix.class,
+ IpAddress.class,
List.class,
ConnectPoint.class
).build()))