Store frameworkid string and deserialise it

ContainerSolutions · Mar 21, 2016 · 084fcd1 · 084fcd1
1 parent bfef185
commit 084fcd1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/.../src/main/java/com/containersolutions/mesos/scheduler/state/StateRepositoryZookeeper.java b/.../src/main/java/com/containersolutions/mesos/scheduler/state/StateRepositoryZookeeper.java
@@ -42,14 +42,14 @@ public Optional<Protos.FrameworkID> getFrameworkID() {
         if (value.length == 0) {
             return Optional.empty();
         }
-        return Optional.of(Protos.FrameworkID.newBuilder().setValue(new String(value)).build());
+        return Optional.of(Protos.FrameworkID.newBuilder().setValue(((String) SerializationUtils.deserialize(value))).build());
     }
 
     @EventListener
     public void onFrameworkRegistered(FrameworkRegistreredEvent event) {
         logger.debug("Received frameworkId=" + event.getFrameworkID().getValue());
         frameworkId.set(event.getFrameworkID());
-        set("frameworkid", frameworkId.get());
+        set("frameworkid", frameworkId.get().getValue());
     }
 
     @EventListener