X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FXMLRouterConfigurationImpl.java;h=679e55df7baa6f4fe9c71066cc6fa37927c7076a;hb=f8027d76e1c3e517a8b80a3476f51adee845fc5b;hp=99db0fd2b65a71b77e0e3eaade316cdbd4bcbf23;hpb=f70baadfd579f4d3aa2e8c9ee7d758fb37d7872f;p=xmlrouter diff --git a/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouterConfigurationImpl.java b/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouterConfigurationImpl.java index 99db0fd..679e55d 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouterConfigurationImpl.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouterConfigurationImpl.java @@ -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())); - } - - @Override - public void startConfigurationChange() { - wlock.lock(); - } - - @Override - public void endConfigurationChange() { - wlock.unlock(); + this(new CompositeRouterConfig(new Id("routerconfig"), + new ArrayList())); } @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