You are viewing a plain text version of this content. The canonical link for it is here.
Posted to muse-dev@ws.apache.org by sc...@apache.org on 2005/03/28 20:42:46 UTC
svn commit: r159278 - in incubator/muse/trunk/src:
java/org/apache/ws/muws/v1_0/ java/org/apache/ws/muws/v1_0/capability/
java/org/apache/ws/muws/v1_0/topics/
java/org/apache/ws/muws/v1_0/topics/impl/
site/content/interop/src/java/org/apache/ws/resource/example/blackberry/
site/content/interop/src/java/org/apache/ws/resource/example/ipmiserver/
site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/
Author: scamp
Date: Mon Mar 28 10:42:43 2005
New Revision: 159278
URL: http://svn.apache.org/viewcvs?view=rev&rev=159278
Log: (empty)
Modified:
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/MuwsConstants.java
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/capability/CorrelatablePropertiesCapability.java
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/ManagementEventTopic.java
incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/XmlBeansManagementEventTopicImpl.java
incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java
incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/ipmiserver/IpmiserverResource.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java
Modified: incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/MuwsConstants.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/MuwsConstants.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/MuwsConstants.java (original)
+++ incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/MuwsConstants.java Mon Mar 28 10:42:43 2005
@@ -22,11 +22,11 @@
*/
public interface MuwsConstants
{
-
+ String PARTIAL_URI_MUWS = "http://docs.oasis-open.org/wsdm/2004/12/";
/**
* The base URI for all URIs defined by the MUWS specs.
*/
- String BASE_URI_MUWS = "http://docs.oasis-open.org/wsdm/2004/12/muws/";
+ String BASE_URI_MUWS = PARTIAL_URI_MUWS + "muws/";
/**
* The base URI for all manageability capability URIs defined by the MUWS specs.
@@ -51,7 +51,12 @@
/**
* Namespace prefix for Properties Boolean Match (PBM) schema.
*/
- String NSPREFIX_PBM = "pbm";
+ String NSPREFIX_PBM = "pbm";
+
+ /**
+ * Dialect used for Properties Boolean Match (PBM)
+ */
+ String NSURI_PBM_DIALECT = PARTIAL_URI_MUWS + "pbm";
/**
* Namespace URI for MUWS Part 2 schema.
Modified: incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/capability/CorrelatablePropertiesCapability.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/capability/CorrelatablePropertiesCapability.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/capability/CorrelatablePropertiesCapability.java (original)
+++ incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/capability/CorrelatablePropertiesCapability.java Mon Mar 28 10:42:43 2005
@@ -50,4 +50,9 @@
*/
QName PROP_NAME_CORRELATABLE_PROPERTIES = new QName( MuwsConstants.NSURI_MUWS_PART1_SCHEMA, "CorrelatableProperties", MuwsConstants.NSPREFIX_MUWS_PART1_SCHEMA );
+ /**
+ * Dialect for PBM
+ */
+ String PBM_DIALECT = MuwsConstants.NSURI_PBM_DIALECT;
+
}
Modified: incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/ManagementEventTopic.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/ManagementEventTopic.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/ManagementEventTopic.java (original)
+++ incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/ManagementEventTopic.java Mon Mar 28 10:42:43 2005
@@ -1,11 +1,13 @@
package org.apache.ws.muws.v1_0.topics;
import org.apache.ws.muws.v1_0.events.ManagementEvent;
+import org.apache.ws.notification.topics.Topic;
+import org.apache.ws.notification.topics.ResourcePropertyValueChangeTopic;
/**
* @author Sal Campana
*/
-public interface ManagementEventTopic
+public interface ManagementEventTopic extends Topic, ResourcePropertyValueChangeTopic
{
/**
* This method is used to send a ManagementEvent to subscribers to this topic.
Modified: incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/XmlBeansManagementEventTopicImpl.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/XmlBeansManagementEventTopicImpl.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/XmlBeansManagementEventTopicImpl.java (original)
+++ incubator/muse/trunk/src/java/org/apache/ws/muws/v1_0/topics/impl/XmlBeansManagementEventTopicImpl.java Mon Mar 28 10:42:43 2005
@@ -19,7 +19,7 @@
/**
* @author Sal Campana
*/
-public class XmlBeansManagementEventTopicImpl extends TopicImpl implements ResourcePropertyValueChangeTopic, ManagementEventTopic
+public class XmlBeansManagementEventTopicImpl extends TopicImpl implements ManagementEventTopic
{
private ManagementEvent m_propChangeManagementEvent;
Modified: incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java (original)
+++ incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java Mon Mar 28 10:42:43 2005
@@ -1,7 +1,7 @@
package org.apache.ws.resource.example.blackberry;
-import org.apache.ws.mows.v1_0.capability.OperationalStatusCapability;
+import org.apache.ws.muws.v1_0.capability.OperationalStatusCapability;
import org.apache.ws.muws.v1_0.capability.ConfigurationCapability;
import org.apache.ws.muws.v1_0.capability.IdentityCapability;
import org.apache.ws.muws.v1_0.capability.MetricsCapability;
Modified: incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/ipmiserver/IpmiserverResource.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/ipmiserver/IpmiserverResource.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/ipmiserver/IpmiserverResource.java (original)
+++ incubator/muse/trunk/src/site/content/interop/src/java/org/apache/ws/resource/example/ipmiserver/IpmiserverResource.java Mon Mar 28 10:42:43 2005
@@ -1,7 +1,7 @@
package org.apache.ws.resource.example.ipmiserver;
-import org.apache.ws.mows.v1_0.capability.OperationalStatusCapability;
+import org.apache.ws.muws.v1_0.capability.OperationalStatusCapability;
import org.apache.ws.muws.v1_0.capability.IdentityCapability;
import org.apache.ws.resource.example.blackberry.BlackberryPropertyQNames;
import org.apache.ws.resource.properties.ResourceProperty;
Modified: incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java (original)
+++ incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java Mon Mar 28 10:42:43 2005
@@ -24,6 +24,27 @@
QName CURRENTTIME =
new QName( "http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part2.xsd", "CurrentTime", "muws-xs2");
QName RELATIONSHIP =
- new QName( "http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part2.xsd", "Relationship", "muws-xs2");
-
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part2.xsd", "Relationship", "muws-xs2");
+
+ QName CURRENTOPERATIONALSTATE =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "CurrentOperationalState", "mows-xs");
+ QName LASTOPERATIONALSTATETRANSITION =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "LastOperationalStateTransition", "mows-xs");
+ QName ENDPOINTREFERENCE =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "EndpointReference", "mows-xs");
+ QName ENDPOINTDESCRIPTIONS =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "EndpointDescriptions", "mows-xs");
+ QName NUMBEROFREQUESTS =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "NumberOfRequests", "mows-xs");
+ QName NUMBEROFSUCCESSFULREQUESTS =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "NumberOfSuccessfulRequests", "mows-xs");
+ QName NUMBEROFFAILEDREQUESTS =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "NumberOfFailedRequests", "mows-xs");
+ QName SERVICETIME =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "ServiceTime", "mows-xs");
+ QName MAXRESPONSETIME =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "MaxResponseTime", "mows-xs");
+ QName LASTRESPONSETIME =
+ new QName( "http://docs.oasis-open.org/wsdm/2004/12/mows/wsdm-mows.xsd", "LastResponseTime", "mows-xs");
+
}
Modified: incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java?view=diff&r1=159277&r2=159278
==============================================================================
--- incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java (original)
+++ incubator/muse/trunk/src/site/content/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java Mon Mar 28 10:42:43 2005
@@ -3,22 +3,49 @@
import org.apache.ws.mows.v1_0.capability.EndpointIdentificationCapability;
import org.apache.ws.mows.v1_0.capability.EndpointMetricsCapability;
-import org.apache.ws.mows.v1_0.capability.OperationalStatusCapability;
+import org.apache.ws.muws.v1_0.capability.OperationalStatusCapability;
import org.apache.ws.mows.v1_0.capability.RequestProcessingStateCapability;
+import org.apache.ws.mows.v1_0.capability.ManageabilityReferencesCapability;
+import org.apache.ws.mows.v1_0.MowsConstants;
import org.apache.ws.muws.v1_0.capability.CorrelatablePropertiesCapability;
import org.apache.ws.muws.v1_0.capability.IdentityCapability;
import org.apache.ws.muws.v1_0.capability.MetricsCapability;
import org.apache.ws.muws.v1_0.capability.RelationshipsCapability;
+import org.apache.ws.muws.v1_0.topics.ManagementEventTopic;
+import org.apache.ws.muws.v1_0.topics.impl.XmlBeansManagementEventTopicImpl;
+import org.apache.ws.muws.v1_0.MuwsConstants;
import org.apache.ws.resource.example.blackberry.BlackberryPropertyQNames;
import org.apache.ws.resource.properties.ResourceProperty;
+import org.apache.ws.notification.topics.TopicSpace;
+import org.apache.ws.notification.topics.impl.TopicSpaceImpl;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.xmlbeans.GDuration;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManageabilityCapabilityDocument;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ResourceIdDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.CorrelatablePropertiesDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.CorrelatablePropertiesType;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.CurrentTimeDocument;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.OperationalStatusDocument;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipDocument;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipParticipantType;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipType;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipTypeType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.StateTransitionType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.StateType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmPbm.MatchDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.CurrentOperationalStateDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.LastOperationalStateTransitionDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.EndpointReferenceDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.EndpointDescriptionsDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.NumberOfRequestsDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.NumberOfSuccessfulRequestsDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.NumberOfFailedRequestsDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.ServiceTimeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.MaxResponseTimeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.LastResponseTimeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.OperationalStateType;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.IntegerCounter;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.DurationMetric;
import java.util.Calendar;
@@ -42,26 +69,52 @@
{
super.init();
+ org.apache.ws.notification.topics.TopicSpaceSet topicSpaceSet = getTopicSpaceSet();
/**
* This method call will make all resource properties be exposed
* as Topics. If you would like to change that behaviour you can
* call TopicUtils.addResourcePropertyValueChangeTopic for each
* Topic you'd like to expose property change notifications for.
*/
- org.apache.ws.notification.topics.util.TopicUtils.addResourcePropertyValueChangeTopics(getResourcePropertySet(), getTopicSpaceSet());
-
+ org.apache.ws.notification.topics.util.TopicUtils.addResourcePropertyValueChangeTopics(getResourcePropertySet(), topicSpaceSet);
+
+ TopicSpace muwsTopicSpace = getTopicSpace(MuwsConstants.NSURI_MUWS_PART2_TOPICS);
+ ManagementEventTopic identityCapability = new XmlBeansManagementEventTopicImpl("IdentityCapabiltiy");
+ muwsTopicSpace.addTopic(identityCapability);
+ ManagementEventTopic manageabilityCharacteristicsCapability = new XmlBeansManagementEventTopicImpl("ManageabilityCharacteristicsCapability");
+ muwsTopicSpace.addTopic(manageabilityCharacteristicsCapability);
+ ManagementEventTopic correlatablePropertiesCapability = new XmlBeansManagementEventTopicImpl("CorrelatablePropertiesCapability");
+ muwsTopicSpace.addTopic(correlatablePropertiesCapability);
+ ManagementEventTopic metricsCapability = new XmlBeansManagementEventTopicImpl("MetricsCapability");
+ muwsTopicSpace.addTopic(metricsCapability);
+ ManagementEventTopic relationshipCapability = new XmlBeansManagementEventTopicImpl("RelationshipCapability");
+ muwsTopicSpace.addTopic(relationshipCapability);
+ ManagementEventTopic operationalStatusCapability = new XmlBeansManagementEventTopicImpl("OperationalStatusCapability");
+ muwsTopicSpace.addTopic(operationalStatusCapability);
+
+
+ TopicSpace mowsTopicSpace = getTopicSpace(MowsConstants.NSURI_MOWS_TOPICS);
+ ManagementEventTopic mowsIdentificationCapability = new XmlBeansManagementEventTopicImpl("IdentificationCapability");
+ mowsTopicSpace.addTopic(mowsIdentificationCapability);
+ ManagementEventTopic mowsMetricsCapability = new XmlBeansManagementEventTopicImpl("MetricsCapability");
+ mowsTopicSpace.addTopic(mowsMetricsCapability);
+ ManagementEventTopic mowsRequestProcessingStateCapability = new XmlBeansManagementEventTopicImpl("RequestProcessingStateCapability");
+ mowsTopicSpace.addTopic(mowsRequestProcessingStateCapability);
+
org.apache.ws.resource.properties.ResourcePropertySet resourcePropertySet = getResourcePropertySet();
/** Capabilities **/
//Management Characteristics
ResourceProperty resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.MANAGEABILITYCAPABILITY);
+ resourceProperty.addChangeListener(manageabilityCharacteristicsCapability);
//Identity Capability
ManageabilityCapabilityDocument manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(IdentityCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+
//Identification Capability
manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(EndpointIdentificationCapability.URI);
@@ -72,31 +125,41 @@
manageabilityCapabilityDocument.setManageabilityCapability(MetricsCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+
//MOWS Metrics Capability
manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(EndpointMetricsCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+
//Status Capability
manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(OperationalStatusCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+
//Request Processing State Capability
manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(RequestProcessingStateCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+
//Relationship Capability
manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(RelationshipsCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+
//Correlateable Properties Capability
manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
manageabilityCapabilityDocument.setManageabilityCapability(CorrelatablePropertiesCapability.URI);
resourceProperty.add(manageabilityCapabilityDocument);
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability(ManageabilityReferencesCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+
//todo setup mows:epr, mows:epdesc
//todo
@@ -105,6 +168,7 @@
ResourceIdDocument resourceIdDocument = ResourceIdDocument.Factory.newInstance();
resourceIdDocument.setResourceId((String)getID());
resourceProperty.add(resourceIdDocument);
+ resourceProperty.addChangeListener(identityCapability);//add for management events
//current time is done like in Apollo
resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.CURRENTTIME);
@@ -112,16 +176,28 @@
currentTimeDocument.setCurrentTime(Calendar.getInstance());
resourceProperty.add(currentTimeDocument);
resourceProperty.setCallback( new org.apache.ws.resource.lifetime.callback.CurrentTimeCallback( ) );
-
+ resourceProperty.addChangeListener(metricsCapability);//add for management events
resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.OPERATIONALSTATUS);
OperationalStatusDocument operationalStatusDocument = OperationalStatusDocument.Factory.newInstance();
operationalStatusDocument.setOperationalStatus(OperationalStatusDocument.OperationalStatus.AVAILABLE);
resourceProperty.add(operationalStatusDocument);
+ resourceProperty.addChangeListener(operationalStatusCapability);//add for management events
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.CORRELATABLEPROPERTIES);
+ CorrelatablePropertiesDocument correlatablePropertiesDocument = CorrelatablePropertiesDocument.Factory.newInstance();
+ CorrelatablePropertiesType correlatablePropertiesType = correlatablePropertiesDocument.addNewCorrelatableProperties();
+ correlatablePropertiesType.setDialect(MuwsConstants.NSURI_PBM);
+ correlatablePropertiesType.setNegativeAssertionPossible(false);
+ MatchDocument matchDocument = MatchDocument.Factory.newInstance();
+ matchDocument.setMatch(WeatherstationPropertyQNames.FCCID);
+ XmlBeanUtils.addChildElement(correlatablePropertiesType, matchDocument);
+ resourceProperty.add(correlatablePropertiesDocument);
+ resourceProperty.addChangeListener(correlatablePropertiesCapability);//add for management events
//todo this is only started....
resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.RELATIONSHIP);
+ resourceProperty.addChangeListener(relationshipCapability);//add for management events
RelationshipDocument relationshipDocument = RelationshipDocument.Factory.newInstance();
//add new type
@@ -139,7 +215,82 @@
RelationshipTypeType relationshipTypeType = relationshipType.addNewType();
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.CURRENTOPERATIONALSTATE);
+ CurrentOperationalStateDocument currentOperationalStateDocument = CurrentOperationalStateDocument.Factory.newInstance();
+ OperationalStateType operationalStateType = currentOperationalStateDocument.addNewCurrentOperationalState();
+ //todo??
+ resourceProperty.add(currentOperationalStateDocument);
+ //todo not sure about change listener
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.LASTOPERATIONALSTATETRANSITION);
+ LastOperationalStateTransitionDocument lastOperationalStateTransitionDocument = LastOperationalStateTransitionDocument.Factory.newInstance();
+ StateTransitionType stateTransitionType = lastOperationalStateTransitionDocument.addNewLastOperationalStateTransition();
+ StateType stateType = stateTransitionType.addNewEnteredState();
+ StateType prevStateType = stateTransitionType.addNewPreviousState();
+ stateTransitionType.setTime(Calendar.getInstance());
+ stateTransitionType.setTransitionIdentifier("");
+ resourceProperty.add(lastOperationalStateTransitionDocument);
+ //todo not sure about change listener
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.ENDPOINTREFERENCE);
+ EndpointReferenceDocument endpointReferenceDocument = EndpointReferenceDocument.Factory.newInstance();
+ endpointReferenceDocument.setEndpointReference(null);//todo need the epr
+ resourceProperty.add(endpointReferenceDocument);
+ resourceProperty.addChangeListener(mowsIdentificationCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.ENDPOINTDESCRIPTIONS);
+ EndpointDescriptionsDocument endpointDescriptionsDocument = EndpointDescriptionsDocument.Factory.newInstance();
+ EndpointDescriptionsDocument.EndpointDescriptions endpointDescriptions = endpointDescriptionsDocument.addNewEndpointDescriptions();
+ endpointDescriptions.addDescription("");
+ resourceProperty.add(endpointDescriptionsDocument);
+ resourceProperty.addChangeListener(mowsIdentificationCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.NUMBEROFREQUESTS);
+ NumberOfRequestsDocument numberOfRequestsDocument = NumberOfRequestsDocument.Factory.newInstance();
+ IntegerCounter integerCounter = numberOfRequestsDocument.addNewNumberOfRequests();
+ integerCounter.setDuration(new GDuration( )); //todo what is this?!?
+ resourceProperty.add(numberOfRequestsDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.NUMBEROFSUCCESSFULREQUESTS);
+ NumberOfSuccessfulRequestsDocument numberOfSuccessfulRequestsDocument = NumberOfSuccessfulRequestsDocument.Factory.newInstance();
+ IntegerCounter successIntegerCounter = numberOfSuccessfulRequestsDocument.addNewNumberOfSuccessfulRequests();
+ resourceProperty.add(numberOfSuccessfulRequestsDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.NUMBEROFFAILEDREQUESTS);
+ NumberOfFailedRequestsDocument numberOfFailedRequestsDocument = NumberOfFailedRequestsDocument.Factory.newInstance();
+ IntegerCounter failedIntegerCounter = numberOfFailedRequestsDocument.addNewNumberOfFailedRequests();
+ resourceProperty.add(numberOfFailedRequestsDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.SERVICETIME);
+ ServiceTimeDocument serviceTimeDocument = ServiceTimeDocument.Factory.newInstance();
+ DurationMetric durationMetric = serviceTimeDocument.addNewServiceTime();
+ resourceProperty.add(serviceTimeDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.MAXRESPONSETIME);
+ MaxResponseTimeDocument maxResponseTimeDocument = MaxResponseTimeDocument.Factory.newInstance();
+ DurationMetric maxRespDurationMetric = maxResponseTimeDocument.addNewMaxResponseTime();
+ resourceProperty.add(maxResponseTimeDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.LASTRESPONSETIME);
+ LastResponseTimeDocument lastResponseTimeDocument = LastResponseTimeDocument.Factory.newInstance();
+ DurationMetric lastRespDurationMetric = lastResponseTimeDocument.addNewLastResponseTime();
+ resourceProperty.add(lastResponseTimeDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+ }
+ private TopicSpace getTopicSpace(String namespace)
+ {
+ TopicSpace topicSpace = getTopicSpaceSet().getTopicSpace(namespace);
+ if(topicSpace == null)
+ {
+ topicSpace = new TopicSpaceImpl(namespace);
+ }
+ return topicSpace;
}
public void setFCCID(FCCIDDocument fccidDocument)
---------------------------------------------------------------------
To unsubscribe, e-mail: muse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: muse-dev-help@ws.apache.org