You are viewing a plain text version of this content. The canonical link for it is here.
Posted to pubscribe-dev@ws.apache.org by sc...@apache.org on 2005/06/22 16:59:22 UTC
svn commit: r191962 - in
/incubator/hermes/trunk/src/java/org/apache/ws/notification/topics:
impl/ResourceTerminationTopicImpl.java util/TopicUtils.java
Author: scamp
Date: Wed Jun 22 07:59:21 2005
New Revision: 191962
URL: http://svn.apache.org/viewcvs?rev=191962&view=rev
Log: (empty)
Modified:
incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/ResourceTerminationTopicImpl.java
incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/util/TopicUtils.java
Modified: incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/ResourceTerminationTopicImpl.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/ResourceTerminationTopicImpl.java?rev=191962&r1=191961&r2=191962&view=diff
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/ResourceTerminationTopicImpl.java (original)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/impl/ResourceTerminationTopicImpl.java Wed Jun 22 07:59:21 2005
@@ -10,7 +10,7 @@
*/
public class ResourceTerminationTopicImpl extends TopicImpl implements ResourceTerminationListener
{
- private static final String TOPIC_NAME = "ResourceTermination";
+ public static final String TOPIC_NAME = "ResourceTermination";
/**
* This provides the version of the topic we are dealing with for use when creating the notification.
Modified: incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/util/TopicUtils.java
URL: http://svn.apache.org/viewcvs/incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/util/TopicUtils.java?rev=191962&r1=191961&r2=191962&view=diff
==============================================================================
--- incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/util/TopicUtils.java (original)
+++ incubator/hermes/trunk/src/java/org/apache/ws/notification/topics/util/TopicUtils.java Wed Jun 22 07:59:21 2005
@@ -64,18 +64,24 @@
topicSpace = new TopicSpaceImpl(namespace);
topicSpaceSet.addTopicSpace(topicSpace);
}
- Topic topic;
- if (topicSpace.topicIterator().hasNext())
+ Topic resourceTerminationTopic = null;
+ while (topicSpace.topicIterator().hasNext())
{
- topic = (Topic) topicSpace.topicIterator().next();
+ Topic topic = (Topic) topicSpace.topicIterator().next();
+ if(topic.getName().equals(ResourceTerminationTopicImpl.TOPIC_NAME))
+ {
+ resourceTerminationTopic = topic;
+ break;
+ }
}
- else
+
+ if(resourceTerminationTopic == null)
{
- topic = new ResourceTerminationTopicImpl(namespaces);
- resource.addTerminationListener((ResourceTerminationListener) topic);
- topicSpace.addTopic(topic);
+ resourceTerminationTopic = new ResourceTerminationTopicImpl(namespaces);
+ resource.addTerminationListener((ResourceTerminationListener) resourceTerminationTopic);
+ topicSpace.addTopic(resourceTerminationTopic);
}
- return topic;
+ return resourceTerminationTopic;
}
/**
---------------------------------------------------------------------
To unsubscribe, e-mail: pubscribe-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: pubscribe-dev-help@ws.apache.org