X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FConfigImpl.java;h=0e1da0be84853fb6b7690d5ddecfef1f1bd3c3ed;hb=5582d07a1ba9821cc789ea63b71f246e89d13cae;hp=75b8222c04363038f3ed289eb5386a9c7843aded;hpb=06368da424915190303bcb501f0cc4cd1b74a2f2;p=xmlrouter diff --git a/impl/src/main/java/org/wamblee/xmlrouter/impl/ConfigImpl.java b/impl/src/main/java/org/wamblee/xmlrouter/impl/ConfigImpl.java index 75b8222..0e1da0b 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/ConfigImpl.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/ConfigImpl.java @@ -17,13 +17,14 @@ package org.wamblee.xmlrouter.impl; import static org.wamblee.xmlrouter.impl.MessageUtil.*; -import java.util.ArrayList; +import java.util.Collection; import java.util.Collections; -import java.util.Iterator; -import java.util.List; +import java.util.HashMap; +import java.util.Map; import org.wamblee.xmlrouter.common.Id; import org.wamblee.xmlrouter.config.Config; +import org.wamblee.xmlrouter.config.ConfigException; import org.wamblee.xmlrouter.config.Identifiable; /** @@ -33,21 +34,42 @@ import org.wamblee.xmlrouter.config.Identifiable; * * @param */ -// TODO make sure that each item inside this config is prefixed with the id of -// the config. public abstract class ConfigImpl> implements ExtendedConfig { + private Class type; private Id id; - private List registered; + private Map, T> registered; /** * Constructs the object. */ - public ConfigImpl(Id aId) { + public ConfigImpl(Class aType, Id aId) { + notNull("type", aType); notNull("id", aId); + type = aType; id = aId; - registered = new ArrayList(); + registered = new HashMap, T>(); + } + + @Override + public Class getType() { + return type; + } + + /** + * Copies the config object. + * + * @param aConfig + * Config to copy. + */ + public ConfigImpl(ConfigImpl aConfig) { + notNull("config", aConfig); + id = aConfig.id; + registered = new HashMap, T>(); + for (Map.Entry, T> entry : aConfig.registered.entrySet()) { + registered.put(entry.getKey(), entry.getValue()); + } } @Override @@ -63,7 +85,10 @@ public abstract class ConfigImpl> implements @Override public synchronized void add(T aT) { notNull("aT", aT); - registered.add(wrap(id.getId() + ".", aT)); + if (registered.containsKey(aT.getId())) { + throw new ConfigException("Duplicate id '" + aT.getId() + "'"); + } + registered.put(aT.getId(), wrap(id.getId() + ".", aT)); } /** @@ -85,19 +110,33 @@ public abstract class ConfigImpl> implements @Override public synchronized boolean remove(Id aId) { notNull("aId", aId); - Iterator i = registered.iterator(); - while (i.hasNext()) { - T t = i.next(); - if (t.getId().equals(aId)) { - i.remove(); - return true; - } + T value = registered.get(aId); + if (value != null) { + registered.remove(aId); + return true; } return false; } @Override - public List values() { - return Collections.unmodifiableList(registered); + public Collection values() { + return Collections.unmodifiableCollection(registered.values()); + } + + @Override + public boolean equals(Object aObj) { + if (aObj == null) { + return false; + } + if (!(aObj instanceof ConfigImpl)) { + return false; + } + ConfigImpl obj = (ConfigImpl) aObj; + return registered.keySet().equals(obj.registered.keySet()); + } + + @Override + public int hashCode() { + return registered.keySet().hashCode(); } }