X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fwamblee%2Fxmlrouter%2Fimpl%2FXMLRouter.java;h=9c0f2d4937e8ad5ff068da5d97aec56c09efabf5;hb=3b2c669b25bfcb5a3c3f06ff9180d85143bebb2a;hp=e86593d274642c3a18500a899e4a9d4b78255103;hpb=5b4ee8d862b98d127abb04c646017c184d005838;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 e86593d..9c0f2d4 100644 --- a/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouter.java +++ b/impl/src/main/java/org/wamblee/xmlrouter/impl/XMLRouter.java @@ -17,7 +17,6 @@ package org.wamblee.xmlrouter.impl; import java.util.ArrayList; import java.util.Collection; -import java.util.Collections; import java.util.HashSet; import java.util.LinkedHashMap; import java.util.List; @@ -30,11 +29,11 @@ import java.util.logging.Logger; import javax.xml.transform.dom.DOMSource; import org.wamblee.general.Clock; +import org.wamblee.general.Pair; import org.wamblee.xml.XMLDocument; import org.wamblee.xmlrouter.common.Id; 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; @@ -42,117 +41,61 @@ import org.wamblee.xmlrouter.publish.Gateway; import org.wamblee.xmlrouter.subscribe.Destination; import org.wamblee.xmlrouter.subscribe.DestinationRegistry; -// TODO concurrency. - -public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { +/** + * The XML Router. + * + * @author Erik Brakkee + * + */ +public class XMLRouter implements Gateway, DestinationRegistry { private static final Logger LOGGER = Logger.getLogger(XMLRouter.class .getName()); + private AtomicLong sequenceNumbers; private EventListener listener; private Clock clock; private AtomicLong nextEventId; - private AtomicLong sequenceNumbers; - private Map, DocumentType> documentTypes; - private Transformations transformations; - private Map, Filter> filters; + + private XMLRouterConfiguration config; + private Map, Destination> destinations; - public XMLRouter(Clock aClock, EventListener aListener) { + public XMLRouter(Clock aClock, XMLRouterConfiguration aConfig, + EventListener aListener) { + sequenceNumbers = new AtomicLong(1); listener = aListener; clock = aClock; nextEventId = new AtomicLong(clock.currentTimeMillis()); - sequenceNumbers = new AtomicLong(1); - documentTypes = new LinkedHashMap, DocumentType>(); - transformations = new Transformations(); - filters = new LinkedHashMap, Filter>(); + config = aConfig; destinations = new LinkedHashMap, Destination>(); } - @Override - public Id addDocumentType(DocumentType aType) { - long seqno = sequenceNumbers.getAndIncrement(); - documentTypes.put(new Id(seqno), aType); - return new Id(seqno); - } - - @Override - public void removeDocumentType(Id aId) { - documentTypes.remove(aId); - } - - @Override - public Collection> getDocumentTypes() { - return Collections.unmodifiableCollection(documentTypes.keySet()); - } - - @Override - public DocumentType getDocumentType(Id aId) { - return documentTypes.get(aId); - } - - @Override - public Id addTransformation(Transformation aTransformation) { - return transformations.addTransformation(aTransformation); - } - - @Override - public void removeTransformation(Id aId) { - transformations.removeTransformation(aId); - } - - @Override - public Collection> getTransformations() { - return transformations.getTransformations(); - } - - @Override - public Transformation getTransformation(Id aId) { - return transformations.getTransformation(aId); - } - - @Override - public Id addFilter(Filter aFilter) { - long seqno = sequenceNumbers.getAndIncrement(); - filters.put(new Id(seqno), aFilter); - return new Id(seqno); - } - - @Override - public void removeFilter(Id aId) { - filters.remove(aId); - } - - @Override - public Collection> getFilters() { - return Collections.unmodifiableCollection(filters.keySet()); - } - - @Override - public Filter getFilter(Id aId) { - return filters.get(aId); - } - @Override public void publish(String aSource, DOMSource aEvent) { - long time = clock.currentTimeMillis(); - Id id = new Id(nextEventId.getAndIncrement()); - List types = determineDocumentTypes(aEvent); + + Pair snapshotconfig = config + .getConfig(); + + Id id = new Id(nextEventId.getAndIncrement() + ""); + List types = determineDocumentTypes(snapshotconfig.getFirst() + .documentTypeConfig().values(), aEvent); EventInfo info = new EventInfo(time, aSource, id, types, aEvent); boolean delivered = false; try { List filteredInputTypes = determineFilteredInputTypes( - types, aEvent); + snapshotconfig.getFirst().filterConfig().values(), types, + aEvent); if (filteredInputTypes.isEmpty()) { if (LOGGER.isLoggable(Level.FINE)) { String doc = new XMLDocument(aEvent).print(true); LOGGER .log( Level.FINE, - "Event ''0}'' from source {1} removed because of filters.", + "Event ''{0}'' from source ''{1}'' removed because of filters.", new Object[] { doc, aSource }); } } @@ -164,7 +107,9 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { // This is however certainly not the main case. for (String inputType : filteredInputTypes) { - boolean result = deliverEvent(info, inputType); + boolean result = deliverEvent(snapshotconfig.getFirst() + .filterConfig().values(), snapshotconfig.getSecond(), info, + inputType); delivered = delivered || result; } } finally { @@ -175,11 +120,12 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { } } - private boolean deliverEvent(EventInfo aInfo, String aInputType) { + private boolean deliverEvent(Collection aFilters, + TransformationPaths aTransformations, EventInfo aInfo, String aInputType) { boolean delivered = false; Set possibleTargetTypes = new HashSet(); - possibleTargetTypes.addAll(transformations + possibleTargetTypes.addAll(aTransformations .getPossibleTargetTypes(aInputType)); // ask each destination what target types, if any they want to have. @@ -192,7 +138,7 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { if (!requested.isEmpty()) { // Deliver to the destination. for (String targetType : requested) { - TransformationPath path = transformations.getPath( + TransformationPath path = aTransformations.getPath( aInputType, targetType); List ts = path.getTransformations(); int i = 0; @@ -207,7 +153,8 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { aInfo.getEvent(), aInputType, t, orig); } - if (!isAllowedByFilters(t.getToType(), transformed)) { + if (!isAllowedByFilters(aFilters, t.getToType(), + transformed)) { allowed = false; } i++; @@ -217,7 +164,7 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { // allow the event. boolean result = destination.receive(transformed); listener.delivered(aInfo, ts, destinationId.getId(), - destination.getName(), result); + result); delivered = delivered || result; } @@ -227,13 +174,13 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { return delivered; } - private List determineFilteredInputTypes(List aTypes, - DOMSource aEvent) { + private List determineFilteredInputTypes( + Collection aFilters, List aTypes, DOMSource aEvent) { // apply filters to the input List filteredTypes = new ArrayList(); for (String type : aTypes) { - boolean allowed = isAllowedByFilters(type, aEvent); + boolean allowed = isAllowedByFilters(aFilters, type, aEvent); if (allowed) { filteredTypes.add(type); } @@ -241,9 +188,10 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { return filteredTypes; } - private boolean isAllowedByFilters(String aType, DOMSource aEvent) { + private boolean isAllowedByFilters(Collection aFilters, + String aType, DOMSource aEvent) { boolean allowed = true; - for (Filter filter : filters.values()) { + for (Filter filter : aFilters) { if (!filter.isAllowed(aType, aEvent)) { allowed = false; } @@ -251,9 +199,10 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { return allowed; } - private List determineDocumentTypes(DOMSource aEvent) { + private List determineDocumentTypes( + Collection aTypes, DOMSource aEvent) { List res = new ArrayList(); - for (DocumentType type : documentTypes.values()) { + for (DocumentType type : aTypes) { if (type.isInstance(aEvent)) { res.add(type.getName()); } @@ -261,18 +210,6 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { return res; } - private void logEvent(String aMessage, String aSource, DOMSource aEvent, - Exception aException) { - LOGGER.log(Level.WARNING, aMessage + ": source '" + aSource + - "': Event: '" + new XMLDocument(aEvent).print(true) + "'", - aException); - } - - private void logEvent(String aMessage, String aSource, DOMSource aEvent) { - LOGGER.log(Level.WARNING, - aMessage + ": " + eventToString(aSource, aEvent)); - } - private String eventToString(String aSource, DOMSource aEvent) { return "source '" + aSource + "': Event: '" + new XMLDocument(aEvent).print(true) + "'"; @@ -295,7 +232,7 @@ public class XMLRouter implements RouterConfig, Gateway, DestinationRegistry { public Id registerDestination(Destination aDestination) { notNull("destination", aDestination); long seqno = sequenceNumbers.getAndIncrement(); - Id id = new Id(seqno); + Id id = new Id(seqno + ""); destinations.put(id, new RobustDestination(id, aDestination)); return id; }