KryoSerializer usage fix
Change-Id: I48e578b33f4c13272a4aa780ee6718e38c2cbea8
diff --git a/core/store/dist/src/main/java/org/onlab/onos/store/statistic/impl/DistributedStatisticStore.java b/core/store/dist/src/main/java/org/onlab/onos/store/statistic/impl/DistributedStatisticStore.java
index d89ce25..03ae01b 100644
--- a/core/store/dist/src/main/java/org/onlab/onos/store/statistic/impl/DistributedStatisticStore.java
+++ b/core/store/dist/src/main/java/org/onlab/onos/store/statistic/impl/DistributedStatisticStore.java
@@ -4,6 +4,7 @@
import static org.slf4j.LoggerFactory.getLogger;
import com.google.common.collect.ImmutableSet;
+
import org.apache.felix.scr.annotations.Activate;
import org.apache.felix.scr.annotations.Component;
import org.apache.felix.scr.annotations.Deactivate;
@@ -26,9 +27,9 @@
import org.onlab.onos.store.flow.ReplicaInfoService;
import org.onlab.onos.store.serializers.KryoNamespaces;
import org.onlab.onos.store.serializers.KryoSerializer;
+import org.onlab.util.KryoNamespace;
import org.slf4j.Logger;
-
import java.io.IOException;
import java.util.HashSet;
import java.util.Map;
@@ -70,7 +71,9 @@
protected static final KryoSerializer SERIALIZER = new KryoSerializer() {
@Override
protected void setupKryoPool() {
- serializerPool = KryoNamespaces.API.newBuilder()
+ serializerPool = KryoNamespace.newBuilder()
+ .register(KryoNamespaces.API)
+ // register this store specific classes here
.build()
.populate(1);
}