commit | 63c659f048866546925bfd99b0aa6f31db895562 | [log] [tgz] |
---|---|---|
author | Madan Jampani <madan@onlab.us> | Thu Jun 11 00:52:58 2015 -0700 |
committer | Gerrit Code Review <gerrit@onlab.us> | Thu Jun 11 21:45:00 2015 +0000 |
tree | 8415878f9229da1da1d07717412dadf043e2837d | |
parent | bb825d73b9b022aaec4a4e3847534a0d9ea4b4f4 [diff] [blame] |
Support for a distributed queue primitive. Change-Id: I13abb93ec1703105ff0137e137738483a5b6a143
diff --git a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseSerializer.java b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseSerializer.java index 9b6a322..db28826 100644 --- a/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseSerializer.java +++ b/core/store/dist/src/main/java/org/onosproject/store/consistent/impl/DatabaseSerializer.java
@@ -21,6 +21,7 @@ import org.apache.commons.lang3.tuple.ImmutablePair; import org.apache.commons.lang3.tuple.Pair; import org.onlab.util.KryoNamespace; +import org.onosproject.cluster.NodeId; import org.onosproject.store.serializers.KryoNamespaces; import org.onosproject.store.serializers.KryoSerializer; import org.onosproject.store.service.DatabaseUpdate; @@ -78,6 +79,7 @@ .register(Result.Status.class) .register(DefaultTransaction.class) .register(Transaction.State.class) + .register(NodeId.class) .build(); private static final KryoSerializer SERIALIZER = new KryoSerializer() {