Author: scamp
Date: Thu Mar 24 14:06:02 2005
New Revision: 158952
URL: http://svn.apache.org/viewcvs?view=rev&rev=158952
Log: (empty)
Added:
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/ManagementEventTopicImpl.java
Added:
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/ManagementEventTopicImpl.java
URL:
http://svn.apache.org/viewcvs/incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/ManagementEventTopicImpl.java?view=auto&rev=158952
==============================================================================
---
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/ManagementEventTopicImpl.java
(added)
+++
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/ManagementEventTopicImpl.java
Thu Mar 24 14:06:02 2005
@@ -0,0 +1,56 @@
+package org.apache.ws.muws.v1_0.topics.impl;
+
+import org.apache.ws.notification.topics.impl.TopicImpl;
+import org.apache.ws.notification.topics.ResourcePropertyValueChangeTopic;
+import org.apache.ws.notification.topics.TopicExpression;
+import org.apache.ws.resource.properties.ResourceProperty;
+import org.apache.ws.resource.properties.ResourcePropertyValueChangeEvent;
+import org.apache.ws.XmlObjectWrapper;
+import org.apache.ws.muws.v1_0.events.ManagementEvent;
+
+import java.util.Map;
+import java.util.Collection;
+import java.util.List;
+
+
+/**
+ * @author Sal Campana
+ */
+public class ManagementEventTopicImpl extends TopicImpl implements
ResourcePropertyValueChangeTopic
+{
+ private ResourceProperty m_prop;
+
+ public ManagementEventTopicImpl( ResourceProperty prop )
+ {
+ super( prop.getMetaData().getName().getLocalPart() );
+ m_prop = prop;
+ }
+
+ public ResourceProperty getResourceProperty()
+ {
+ return m_prop;
+ }
+
+
+ public void propertyChanged(ResourcePropertyValueChangeEvent event)
+ {
+ Object msg;
+ if ( event instanceof XmlObjectWrapper )
+ {
+ msg = ((XmlObjectWrapper)event).getXmlObject();
+ }
+ else
+ {
+ msg = event;
+ }
+ try
+ {
+ publish( msg );
+ }
+ catch ( Exception e )
+ {
+ // TODO: do we want to throw this and cause the SetRP request to
fault?
+ e.printStackTrace();
+ }
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
