Don't attempt to write Executor to Typesafe Config object in Coordina…

…torConfig.
atomix · Feb 3, 2015 · 0207a6e · 0207a6e
1 parent 0e0fcf4
commit 0207a6e
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/src/main/java/net/kuujo/copycat/cluster/internal/coordinator/CoordinatorConfig.java b/core/src/main/java/net/kuujo/copycat/cluster/internal/coordinator/CoordinatorConfig.java
@@ -38,6 +38,8 @@ public class CoordinatorConfig extends AbstractConfigurable {
 
   private final Executor DEFAULT_COORDINATOR_EXECUTOR = Executors.newSingleThreadExecutor(new NamedThreadFactory("copycat-coordinator-%d"));
 
+  private Executor executor;
+
   public CoordinatorConfig() {
     super();
   }
@@ -123,7 +125,7 @@ public CoordinatorConfig withClusterConfig(ClusterConfig config) {
    * @param executor The coordinator executor.
    */
   public void setExecutor(Executor executor) {
-    this.config = config.withValue(COORDINATOR_EXECUTOR, ConfigValueFactory.fromAnyRef(executor));
+    this.executor = executor;
   }
 
   /**
@@ -132,7 +134,7 @@ public void setExecutor(Executor executor) {
    * @return The coordinator executor or {@code null} if no executor was specified.
    */
   public Executor getExecutor() {
-    return config.hasPath (COORDINATOR_EXECUTOR) ? (Executor) config.getValue(COORDINATOR_EXECUTOR).unwrapped() : DEFAULT_COORDINATOR_EXECUTOR;
+    return executor != null ? executor : DEFAULT_COORDINATOR_EXECUTOR;
   }
 
   /**