Merge "Instantiate kryo instance using kryo factory (newKyro)." into dev/ramcloud-new-datamodel
diff --git a/src/main/java/net/onrc/onos/intent/persist/PersistIntent.java b/src/main/java/net/onrc/onos/intent/persist/PersistIntent.java
index 380a0f2..602762b 100755
--- a/src/main/java/net/onrc/onos/intent/persist/PersistIntent.java
+++ b/src/main/java/net/onrc/onos/intent/persist/PersistIntent.java
@@ -17,6 +17,7 @@
import net.onrc.onos.intent.IntentOperationList;
import net.onrc.onos.ofcontroller.networkgraph.INetworkGraphService;
import net.onrc.onos.ofcontroller.networkgraph.NetworkGraph;
+import net.onrc.onos.ofcontroller.util.serializers.KryoFactory;
import net.onrc.onos.registry.controller.IControllerRegistryService;
import net.onrc.onos.registry.controller.IdBlock;
import org.slf4j.Logger;
@@ -34,7 +35,7 @@
private final static String intentJournal = "G:IntentJournal";
private final static int valueStoreLimit = 1024 * 1024;
private RCTable table;
- private Kryo kryo = new Kryo();
+ private Kryo kryo;
private ByteArrayOutputStream stream;
private Output output = null;
private AtomicLong nextId = null;
@@ -48,6 +49,7 @@
table = RCTable.getTable(intentJournal);
stream = new ByteArrayOutputStream(1024);
output = new Output(stream);
+ kryo = (new KryoFactory()).newKryo();
}
public long getKey() {