X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FCompositeConfig.java;fp=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FCompositeConfig.java;h=22052108f5dd780c5eaffc3eb23f0e90bddafca0;hb=03a6b404471945aed9d48fc1e5b8447b4a9d9413;hp=56e3e8b3f7cb799f77e23d68c42a43b2b1a69864;hpb=7b7444ecb86a1af3eb11013e94776c2860205f2a;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 56e3e8b..2205210 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/CompositeConfig.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/CompositeConfig.java @@ -15,11 +15,17 @@ */ package org.wamblee.xmlrouter.impl; +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.DuplicateException; +import org.wamblee.xmlrouter.config.Identifiable; /** * Composite config. The composite config @@ -28,46 +34,57 @@ import org.wamblee.xmlrouter.config.Config; * * @param */ -public class CompositeConfig implements ExtendedConfig { +public class CompositeConfig> implements + ExtendedConfig { + private static final String READ_ONLY_INSTANCE = "read only instance"; + private Set> ids; private Id id; - private List configs; + private List> valueIds; + private List values; public CompositeConfig(Id aId) { + ids = new HashSet>(); id = aId; - configs = new ArrayList(); + valueIds = new ArrayList>(); + values = new ArrayList(); } @Override public Id getId() { - // TODO test id. return id; } - public void add(Config aConfig) { - // TODO check duplicate config. + public void addConfig(Config aConfig) { + if (ids.contains(aConfig.getId())) { + throw new DuplicateException(aConfig.getId().toString()); + } for (T item : aConfig.values()) { - configs.add(item); + if (valueIds.contains(item.getId())) { + throw new DuplicateException(item.getId().toString()); + } + } + + ids.add(aConfig.getId()); + for (T item : aConfig.values()) { + valueIds.add(item.getId()); + values.add(item); } } @Override public List values() { - return configs; + return values; } @Override public boolean remove(Id aId) { - notSupported(); + notSupported(READ_ONLY_INSTANCE); return false; } @Override public void add(T aT) { - notSupported(); - } - - private void notSupported() { - throw new RuntimeException("readonly instance"); + notSupported(READ_ONLY_INSTANCE); } }