Author: scamp Date: Tue Jan 25 08:24:14 2005 New Revision: 126385 URL: http://svn.apache.org/viewcvs?view=rev&rev=126385 Log: added/updated Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/TopicSpaceSetImpl.java Modified: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java
Modified: incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java Url: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java?view=diff&rev=126385&p1=incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java&r1=126384&p2=incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java&r2=126385 ============================================================================== --- incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java (original) +++ incubator/hermes/trunk/src/java/org/apache/ws/notification/base/v1_2/porttype/impl/NotificationProducerPortTypeImpl.java Tue Jan 25 08:24:14 2005 @@ -104,7 +104,9 @@ { GetCurrentMessageDocument.GetCurrentMessage request = requestDoc.getGetCurrentMessage(); TopicExpressionType topicExpr = request.getTopic(); - + //run over topic collection to find topic of interest + //should only eval to 1 topic! + //get last message from topic // TODO return null; } Added: incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/TopicSpaceSetImpl.java Url: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/TopicSpaceSetImpl.java?view=auto&rev=126385 ============================================================================== --- (empty file) +++ incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/TopicSpaceSetImpl.java Tue Jan 25 08:24:14 2005 @@ -0,0 +1,54 @@ +package org.apache.ws.notification.topics.impl; + +import org.apache.ws.notification.topics.TopicSpaceSet; +import org.apache.ws.notification.topics.TopicSpace; +import org.apache.ws.notification.topics.Topic; + +import java.util.List; +import java.util.Map; +import java.util.Hashtable; +import java.util.Iterator; + + +/** + * @author Sal Campana + */ +public class TopicSpaceSetImpl implements TopicSpaceSet +{ + Map m_topicSpaces = new Hashtable(); + + public void addTopicSpace(TopicSpace topicSpace) + { + String namespaceURI = topicSpace.getNamespaceURI(); + //if topicSpace exists, simply add all topics to topicspace + if(m_topicSpaces.containsKey(namespaceURI)) + { + TopicSpace topicSpc = (TopicSpace) m_topicSpaces.get(namespaceURI); + Iterator iterator = topicSpc.topicIterator(); + while (iterator.hasNext()) + { + Topic topic = (Topic) iterator.next(); + topicSpace.addTopic(topic); + } + } + else + { + m_topicSpaces.put(namespaceURI, topicSpace); + } + } + + public void removeTopicSpace(String namespaceURI) + { + m_topicSpaces.remove(namespaceURI); + } + + public TopicSpace getTopicSpace(String namespaceURI) + { + return (TopicSpace) m_topicSpaces.get(namespaceURI); + } + + public TopicSpace[] getTopicSpaces() + { + return (TopicSpace[]) m_topicSpaces.values().toArray(new TopicSpace[0]); + } +} --------------------------------------------------------------------- To unsubscribe, e-mail: [EMAIL PROTECTED] For additional commands, e-mail: [EMAIL PROTECTED]
