X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FConfigImpl.java;h=c561e364b287958a169a90eb611baa58769ed3fc;hb=e52385618670b54a5c6a4f2fbfab381bef43a905;hp=e29725e8655d2be5ad4fab667d4152dca68e37e8;hpb=0db97b9f39c69528900f915dd2bb463c27debe39;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 e29725e..c561e36 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/ConfigImpl.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/ConfigImpl.java @@ -15,13 +15,14 @@ */ package org.wamblee.xmlrouter.impl; +import java.util.ArrayList; import java.util.Collections; -import java.util.LinkedHashMap; -import java.util.Map; -import java.util.concurrent.atomic.AtomicLong; +import java.util.Iterator; +import java.util.List; import org.wamblee.xmlrouter.common.Id; import org.wamblee.xmlrouter.config.Config; +import org.wamblee.xmlrouter.config.Identifiable; /** * Default implementation of the {@link Config} interface. @@ -30,19 +31,24 @@ import org.wamblee.xmlrouter.config.Config; * * @param */ -public abstract class ConfigImpl implements ExtendedConfig { +public abstract class ConfigImpl implements + ExtendedConfig { - private boolean dirty; - private AtomicLong next; - private Map, T> registered; + private Id id; + private List registered; /** * Constructs the object. */ - public ConfigImpl(AtomicLong aNext) { - dirty = false; - next = aNext; - registered = new LinkedHashMap, T>(); + public ConfigImpl(Id aId) { + // TODO test for null. + id = aId; + registered = new ArrayList(); + } + + @Override + public Id getId() { + return id; } /* @@ -51,25 +57,20 @@ public abstract class ConfigImpl implements ExtendedConfig { * @see org.wamblee.xmlrouter.config.Config#add(T) */ @Override - public synchronized Id add(T aT) { + public synchronized void add(T aT) { + // TODO test duplicate ids. notNull(aT); - long seqno = next.incrementAndGet(); - Id id = new Id(seqno); - registered.put(id, wrap(id, aT)); - dirty = true; - return id; + registered.add(wrap(aT)); } /** * This is called to wrap the given object by a safer version. * - * @param aId - * Id. * @param aT * Object to wrap. * @return Wrapped object. */ - public abstract T wrap(Id aId, T aT); + public abstract T wrap(T aT); /* * (non-Javadoc) @@ -81,13 +82,20 @@ public abstract class ConfigImpl implements ExtendedConfig { @Override public synchronized boolean remove(Id aId) { notNull(aId); - dirty = true; - return registered.remove(aId) != null; + Iterator i = registered.iterator(); + while (i.hasNext()) { + T t = i.next(); + if (t.getId().equals(aId)) { + i.remove(); + return true; + } + } + return false; } @Override - public Map, T> map() { - return Collections.unmodifiableMap(registered); + public List values() { + return Collections.unmodifiableList(registered); } private void notNull(T aT) {