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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
