equality based on the ids of the contents of SingleRouterConfig.
[xmlrouter] / impl / src / main / java / org / wamblee / xmlrouter / impl / XMLRouterConfigurationImpl.java
index 99db0fd2b65a71b77e0e3eaade316cdbd4bcbf23..679e55df7baa6f4fe9c71066cc6fa37927c7076a 100644 (file)
@@ -18,6 +18,7 @@ package org.wamblee.xmlrouter.impl;
 import java.util.ArrayList;
 import java.util.concurrent.locks.ReentrantReadWriteLock;
 
+import org.wamblee.xmlrouter.common.Id;
 import org.wamblee.xmlrouter.config.RouterConfig;
 
 /**
@@ -38,21 +39,13 @@ public class XMLRouterConfigurationImpl implements XMLRouterConfiguration {
 
     public XMLRouterConfigurationImpl(ExtendedRouterConfig aConfig) {
         config = aConfig;
-        transformations = new TransformationPaths();
+        transformations = new TransformationPaths(config.transformationConfig()
+            .values());
     }
 
     public XMLRouterConfigurationImpl() {
-        this(new CompositeRouterConfig(new ArrayList<RouterConfig>()));
-    }
-
-    @Override
-    public void startConfigurationChange() {
-        wlock.lock();
-    }
-
-    @Override
-    public void endConfigurationChange() {
-        wlock.unlock();
+        this(new CompositeRouterConfig(new Id<RouterConfig>("routerconfig"),
+            new ArrayList<RouterConfig>()));
     }
 
     @Override
@@ -72,9 +65,17 @@ public class XMLRouterConfigurationImpl implements XMLRouterConfiguration {
 
     @Override
     public void setRouterConfig(ExtendedRouterConfig aConfig) {
-        config = aConfig;
-        transformations.replaceTransformations(config.transformationConfig()
-            .map());
+
+        TransformationPaths newTransformations = new TransformationPaths(
+            aConfig.transformationConfig().values());
+
+        wlock.lock();
+        try {
+            config = aConfig;
+            transformations = newTransformations;
+        } finally {
+            wlock.unlock();
+        }
     }
 
     @Override