Serializer related fixes

- DefaultGroupId is part of API
- KryoNamespace is thread-safe, use same instance.

Change-Id: I492f48c2ae9239edb5742c00231cd24b4d6db6a3

@@ -144,8 +144,6 @@ public class DistributedGroupStore
 
 
     private final AtomicInteger groupIdGen = new AtomicInteger();
     private final AtomicInteger groupIdGen = new AtomicInteger();
 
 
-    private KryoNamespace.Builder kryoBuilder = null;
-
     private KryoNamespace clusterMsgSerializer;
     private KryoNamespace clusterMsgSerializer;
 
 
     @Property(name = "garbageCollect", boolValue = GARBAGE_COLLECT,
     @Property(name = "garbageCollect", boolValue = GARBAGE_COLLECT,
@@ -160,8 +158,9 @@ public class DistributedGroupStore
     @Activate
     @Activate
     public void activate() {
     public void activate() {
         cfgService.registerProperties(getClass());
         cfgService.registerProperties(getClass());
-        kryoBuilder = new KryoNamespace.Builder()
+        KryoNamespace.Builder kryoBuilder = new KryoNamespace.Builder()
                 .register(KryoNamespaces.API)
                 .register(KryoNamespaces.API)
+                .nextId(KryoNamespaces.BEGIN_USER_CUSTOM_ID)
                 .register(DefaultGroup.class,
                 .register(DefaultGroup.class,
                           DefaultGroupBucket.class,
                           DefaultGroupBucket.class,
                           DefaultGroupDescription.class,
                           DefaultGroupDescription.class,
@@ -169,7 +168,6 @@ public class DistributedGroupStore
                           GroupDescription.Type.class,
                           GroupDescription.Type.class,
                           Group.GroupState.class,
                           Group.GroupState.class,
                           GroupBuckets.class,
                           GroupBuckets.class,
-                          DefaultGroupId.class,
                           GroupStoreMessage.class,
                           GroupStoreMessage.class,
                           GroupStoreMessage.Type.class,
                           GroupStoreMessage.Type.class,
                           UpdateType.class,
                           UpdateType.class,
@@ -180,7 +178,8 @@ public class DistributedGroupStore
                           GroupStoreMapKey.class
                           GroupStoreMapKey.class
                 );
                 );
 
 
-        clusterMsgSerializer = kryoBuilder.build();
+        clusterMsgSerializer = kryoBuilder.build("GroupStore");
+        Serializer serializer = Serializer.using(clusterMsgSerializer);
 
 
         messageHandlingExecutor = Executors.
         messageHandlingExecutor = Executors.
                 newFixedThreadPool(MESSAGE_HANDLER_THREAD_POOL_SIZE,
                 newFixedThreadPool(MESSAGE_HANDLER_THREAD_POOL_SIZE,
@@ -197,7 +196,7 @@ public class DistributedGroupStore
 
 
         groupStoreEntriesByKey = storageService.<GroupStoreKeyMapKey, StoredGroupEntry>consistentMapBuilder()
         groupStoreEntriesByKey = storageService.<GroupStoreKeyMapKey, StoredGroupEntry>consistentMapBuilder()
                 .withName("onos-group-store-keymap")
                 .withName("onos-group-store-keymap")
-                .withSerializer(Serializer.using(kryoBuilder.build()))
+                .withSerializer(serializer)
                 .build();
                 .build();
         groupStoreEntriesByKey.addListener(new GroupStoreKeyMapListener());
         groupStoreEntriesByKey.addListener(new GroupStoreKeyMapListener());
         log.debug("Current size of groupstorekeymap:{}",
         log.debug("Current size of groupstorekeymap:{}",
@@ -207,7 +206,7 @@ public class DistributedGroupStore
 
 
         auditPendingReqQueue = storageService.<GroupStoreKeyMapKey, StoredGroupEntry>consistentMapBuilder()
         auditPendingReqQueue = storageService.<GroupStoreKeyMapKey, StoredGroupEntry>consistentMapBuilder()
                 .withName("onos-pending-group-keymap")
                 .withName("onos-pending-group-keymap")
-                .withSerializer(Serializer.using(kryoBuilder.build()))
+                .withSerializer(serializer)
                 .build();
                 .build();
         log.debug("Current size of pendinggroupkeymap:{}",
         log.debug("Current size of pendinggroupkeymap:{}",
                   auditPendingReqQueue.size());
                   auditPendingReqQueue.size());