X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FCompositeConfig.java;h=0c6100dc3fc82c2c9a4484bc2af21e258e84d7a0;hb=2e9a88b0478d074974818dc384ca45c2bf4fdaa5;hp=b378052c207b05015b78d427870070c733e7dcbf;hpb=f70baadfd579f4d3aa2e8c9ee7d758fb37d7872f;p=xmlrouter diff --git a/impl/src/main/java/org/wamblee/xmlrouter/impl/CompositeConfig.java b/impl/src/main/java/org/wamblee/xmlrouter/impl/CompositeConfig.java index b378052..0c6100d 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/CompositeConfig.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/CompositeConfig.java @@ -15,44 +15,91 @@ */ package org.wamblee.xmlrouter.impl; -import java.util.LinkedHashMap; -import java.util.Map; +import static org.wamblee.xmlrouter.impl.MessageUtil.*; + +import java.util.ArrayList; +import java.util.HashSet; +import java.util.List; +import java.util.Set; import org.wamblee.xmlrouter.common.Id; import org.wamblee.xmlrouter.config.Config; +import org.wamblee.xmlrouter.config.ConfigException; +import org.wamblee.xmlrouter.config.Identifiable; + +/** + * Composite config. The composite config + * + * @author Erik Brakkee + * + * @param + */ +public class CompositeConfig> implements + ExtendedConfig { -public class CompositeConfig implements ExtendedConfig { + private static final Id ID = new Id("compositeconfig"); + private static final String READ_ONLY_INSTANCE = "read only instance"; - private Map, T> configs; + private Class type; + private Set> ids; + private List> valueIds; + private List values; - public CompositeConfig() { - configs = new LinkedHashMap, T>(); + public CompositeConfig(Class aType) { + type = aType; + ids = new HashSet>(); + valueIds = new ArrayList>(); + values = new ArrayList(); } - public void add(Config aConfig) { - for (Id id : aConfig.map().keySet()) { - configs.put(id, aConfig.map().get(id)); + @Override + public Class getType() { + return type; + } + + @Override + public Id getId() { + return ID; + } + + public void addConfig(Config aConfig) { + notNull("aConfig", aConfig); + if (ids.contains(aConfig.getId())) { + throw new ConfigException("duplicate id '" + + aConfig.getId().toString() + "'"); + } + String prefix = aConfig.getId().getId() + "."; + for (T item : aConfig.values()) { + Id newId = new Id(prefix + item.getId()); + if (valueIds.contains(newId)) { + throw new ConfigException("duplicate id '" + + item.getId().toString() + "'"); + } + } + + ids.add(aConfig.getId()); + + for (T item : aConfig.values()) { + Id newId = new Id(prefix + item.getId()); + valueIds.add(newId); + values.add(IdentifiablePrefixProxyFactory.getProxy(prefix, item, + Identifiable.class, aConfig.getType())); } } @Override - public Map, T> map() { - return configs; + public List values() { + return values; } @Override public boolean remove(Id aId) { - notSupported(); + notSupported(READ_ONLY_INSTANCE); return false; } - private void notSupported() { - throw new RuntimeException("readonly instance"); - } - @Override - public Id add(T aT) { - notSupported(); - return null; + public void add(T aT) { + notSupported(READ_ONLY_INSTANCE); } }