X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FXMLRouter.java;h=d74c93d09f20a99e09c57480952822c2a1ac4a4c;hb=d96c59e2c9e5b15c4ce2023ac93d70b4c0ddf568;hp=8fa78f4a18af15854b1c835dc4378daa44cee59d;hpb=19413a6699295b4bbebc1b3bdb9838fd4370e581;p=xmlrouter diff --git a/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouter.java b/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouter.java index 8fa78f4..d74c93d 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouter.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouter.java @@ -31,10 +31,8 @@ import javax.xml.transform.dom.DOMSource; import org.wamblee.general.Clock; import org.wamblee.xml.XMLDocument; import org.wamblee.xmlrouter.common.Id; -import org.wamblee.xmlrouter.config.Config; import org.wamblee.xmlrouter.config.DocumentType; import org.wamblee.xmlrouter.config.Filter; -import org.wamblee.xmlrouter.config.RouterConfig; import org.wamblee.xmlrouter.config.Transformation; import org.wamblee.xmlrouter.listener.EventInfo; import org.wamblee.xmlrouter.listener.EventListener; @@ -48,7 +46,7 @@ import org.wamblee.xmlrouter.subscribe.DestinationRegistry; * @author Erik Brakkee * */ -public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { +public class XMLRouter implements Gateway, DestinationRegistry { private static final Logger LOGGER = Logger.getLogger(XMLRouter.class .getName()); @@ -59,35 +57,21 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { private AtomicLong nextEventId; private ExtendedRouterConfig routerConfig; - private Transformations transformations; + private TransformationPaths transformations; private Map, Destination> destinations; - public XMLRouter(Clock aClock, EventListener aListener) { + public XMLRouter(Clock aClock, ExtendedRouterConfig aRouterConfig, + EventListener aListener) { sequenceNumbers = new AtomicLong(1); listener = aListener; clock = aClock; nextEventId = new AtomicLong(clock.currentTimeMillis()); - routerConfig = new SingleRouterConfig(sequenceNumbers); - transformations = new Transformations(); + routerConfig = aRouterConfig; + transformations = new TransformationPaths(); destinations = new LinkedHashMap, Destination>(); } - @Override - public Config documentTypeConfig() { - return routerConfig.documentTypeConfig(); - } - - @Override - public Config transformationConfig() { - return routerConfig.transformationConfig(); - } - - @Override - public Config filterConfig() { - return routerConfig.filterConfig(); - } - @Override public void publish(String aSource, DOMSource aEvent) { long time = clock.currentTimeMillis();