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 jr...@apache.org on 2005/07/21 18:37:32 UTC
svn commit: r220138 [10/11] - in
/webservices/muse/trunk/src/examples/interop: ./ lib/ src/ src/.xmlbeans/
src/.xmlbeans/src/ src/.xmlbeans/src/com/ src/.xmlbeans/src/com/dell/
src/.xmlbeans/src/com/dell/wsdm/ src/.xmlbeans/src/com/dell/wsdm/demos/
src...
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationResource.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,381 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import org.apache.ws.mows.v1_0.MowsConstants;
+import org.apache.ws.mows.v1_0.capability.IdentificationCapability;
+import org.apache.ws.mows.v1_0.capability.ManageabilityReferencesCapability;
+import org.apache.ws.mows.v1_0.capability.MetricsCapability;
+import org.apache.ws.mows.v1_0.capability.RequestProcessingStateCapability;
+import org.apache.ws.muws.v1_0.MuwsConstants;
+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.OperationalStatusCapability;
+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.notification.topics.TopicSpace;
+import org.apache.ws.notification.topics.impl.TopicSpaceImpl;
+import org.apache.ws.resource.example.InteropConstants;
+import org.apache.ws.resource.properties.ResourceProperty;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.xmlbeans.GDurationBuilder;
+import org.apache.xmlbeans.XmlException;
+import org.apache.xmlbeans.XmlObject;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.CurrentOperationalStateDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.DurationMetric;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.EndpointDescriptionsDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.EndpointReferenceDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.IntegerCounter;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.LastOperationalStateTransitionDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.LastResponseTimeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.MaxResponseTimeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.NumberOfFailedRequestsDocument;
+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.ServiceTimeDocument;
+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.wsdmMuwsPart1.ManageabilityCapabilityDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ResourceIdDocument;
+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.wsdmPbm.MatchDocument;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.AttributedURI;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.EndpointReferenceType;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.ReferencePropertiesType;
+
+import javax.xml.namespace.QName;
+import java.math.BigDecimal;
+import java.math.BigInteger;
+import java.util.Calendar;
+
+/**
+ * A Weatherstation WS-Resource.
+ * <p/>
+ * NOTE: This class is generated but IS meant to be modified.
+ */
+public class WeatherstationResource extends AbstractWeatherstationResource
+{
+
+ /**
+ * A NamespaceVerionHolder which maintains the QNames of Spec Wsdls
+ */
+ public static final org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl SPEC_NAMESPACE_SET = new org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl();
+
+ public static final QName RELATIONSHIP_RELATION = new QName(WeatherstationPropertyQNames.FCCID.getNamespaceURI(), "containment", "R");
+
+ /**
+ * Initializes this resource's state (properties, etc.).
+ */
+ public void init()
+ {
+ super.init();
+
+ /**
+ * The ResourcePropertySet which contains all the defined ResourceProperties
+ */
+ org.apache.ws.resource.properties.ResourcePropertySet resourcePropertySet = getResourcePropertySet();
+ org.apache.ws.resource.properties.ResourceProperty resourceProperty = null;
+
+
+ try
+ {
+ //MUWS TopicSpace
+ TopicSpace muwsTopicSpace = new TopicSpaceImpl(MuwsConstants.NSURI_MUWS_PART2_TOPICS);
+ getTopicSpaceSet().addTopicSpace(muwsTopicSpace);
+
+ ManagementEventTopic identityCapability = new XmlBeansManagementEventTopicImpl("IdentityCapability");
+ 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);
+
+ //MOWS TopicSpace
+ TopicSpace mowsTopicSpace = new TopicSpaceImpl(MowsConstants.NSURI_MOWS_TOPICS);
+ getTopicSpaceSet().addTopicSpace(mowsTopicSpace);
+
+ ManagementEventTopic mowsIdentificationCapability = new XmlBeansManagementEventTopicImpl("IdentificationCapability");
+ mowsTopicSpace.addTopic(mowsIdentificationCapability);
+ ManagementEventTopic mowsMetricsCapability = new XmlBeansManagementEventTopicImpl("MetricsCapability");
+ mowsTopicSpace.addTopic(mowsMetricsCapability);
+
+ ManagementEventTopic mowsRequestProcessingStateCapability = new XmlBeansManagementEventTopicImpl("RequestProcessingStateCapability");
+ mowsTopicSpace.addTopic(mowsRequestProcessingStateCapability);
+
+ ManagementEventTopic mowsRequestProcessingObservations = new XmlBeansManagementEventTopicImpl("RequestProcessingObservations");
+ mowsTopicSpace.addTopic(mowsRequestProcessingObservations);
+
+ /** Capabilities **/
+ //Management Characteristics
+ 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(IdentificationCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+ //MUWS2 Metrics Capability
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability(org.apache.ws.muws.v1_0.capability.MetricsCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+
+ //MOWS Metrics Capability
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability(MetricsCapability.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);
+
+ /** Properties **/
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.RESOURCEID);
+ ResourceIdDocument resourceIdDocument = ResourceIdDocument.Factory.newInstance();
+ resourceIdDocument.setResourceId("urn:" + (String) getID());
+ resourceProperty.add(resourceIdDocument);
+ resourceProperty.addChangeListener(identityCapability);//add for management events
+
+ //current time is done like in WSRF
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.CURRENTTIME);
+ CurrentTimeDocument currentTimeDocument = CurrentTimeDocument.Factory.newInstance();
+ 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.PBM_DIALECT);
+ 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
+
+ /*----------------- MUWS Relationships props -----------------*/
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.RELATIONSHIP);
+ resourceProperty.addChangeListener(relationshipCapability);//add for management events
+
+ RelationshipDocument relationshipDocument = RelationshipDocument.Factory.newInstance();
+
+ //add new type
+ RelationshipType relationshipType = null;
+ try
+ {
+ relationshipType = relationshipDocument.addNewRelationship();
+ RelationshipTypeType relationshipTypeType = relationshipType.addNewType();
+ XmlObject relationType = XmlObject.Factory.parse("<" + RELATIONSHIP_RELATION.getPrefix() + ":" + RELATIONSHIP_RELATION.getLocalPart() + " xmlns:" + RELATIONSHIP_RELATION.getPrefix() + "=" + "\"" + RELATIONSHIP_RELATION.getNamespaceURI() + "\" />");
+ XmlBeanUtils.addChildElement(relationshipTypeType, relationType);
+ }
+ catch (XmlException e)
+ {
+ e.printStackTrace();
+ }
+
+ QName qName = QName.valueOf("{" + WeatherstationPropertyQNames.FCCID.getNamespaceURI() + "}ResourceID");
+ //add a participant
+ RelationshipParticipantType relationshipParticipantType = relationshipType.addNewParticipant();
+ relationshipParticipantType.setResourceId("urn:" + InteropConstants.WEATHERSTATION_KEY1);
+ relationshipParticipantType.setRole("urn://parent");//uri
+ EndpointReferenceType manageabilityEndpointReferenceType = relationshipParticipantType.addNewManageabilityEndpointReference();
+ manageabilityEndpointReferenceType.addNewAddress().setStringValue(InteropConstants.SERVICES_URL + "/" + InteropConstants.WEATHERSTATION_SERVICE_NAME);
+ ReferencePropertiesType referencePropertiesType = manageabilityEndpointReferenceType.addNewReferenceProperties();
+ XmlObject key1 = XmlBeanUtils.addChildElement(referencePropertiesType, qName);
+ XmlBeanUtils.setValue(key1, InteropConstants.WEATHERSTATION_KEY1);
+
+ RelationshipParticipantType relationshipParticipantType2 = relationshipType.addNewParticipant();
+ relationshipParticipantType2.setResourceId("urn:" + InteropConstants.WEATHERSTATION_KEY2);//spec optional
+ relationshipParticipantType2.setRole("urn://child1");//uri
+ EndpointReferenceType manageabilityEndpointReferenceType2 = relationshipParticipantType.addNewManageabilityEndpointReference();
+ manageabilityEndpointReferenceType2.addNewAddress().setStringValue(InteropConstants.SERVICES_URL + "/" + InteropConstants.WEATHERSTATION_SERVICE_NAME);
+ ReferencePropertiesType referencePropertiesType2 = manageabilityEndpointReferenceType2.addNewReferenceProperties();
+ XmlObject key2 = XmlBeanUtils.addChildElement(referencePropertiesType2, qName);
+ XmlBeanUtils.setValue(key2, InteropConstants.WEATHERSTATION_KEY2);
+
+ resourceProperty.add(relationshipDocument);
+
+ /*----------------- MOWS OperationalState props -----------------*/
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.CURRENTOPERATIONALSTATE);
+ CurrentOperationalStateDocument currentOperationalStateDocument = CurrentOperationalStateDocument.Factory.newInstance();
+ currentOperationalStateDocument.addNewCurrentOperationalState();
+ resourceProperty.add(currentOperationalStateDocument);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.LASTOPERATIONALSTATETRANSITION);
+ LastOperationalStateTransitionDocument lastOperationalStateTransitionDocument = LastOperationalStateTransitionDocument.Factory.newInstance();
+ StateTransitionType stateTransitionType = lastOperationalStateTransitionDocument.addNewLastOperationalStateTransition();
+ stateTransitionType.addNewEnteredState();
+ stateTransitionType.addNewPreviousState();
+ stateTransitionType.setTime(Calendar.getInstance());
+ stateTransitionType.setTransitionIdentifier("");
+ resourceProperty.add(lastOperationalStateTransitionDocument);
+
+ /*----------------- MOWS EndpointIdentification props -----------------*/
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.ENDPOINTREFERENCE);
+ EndpointReferenceDocument endpointReferenceDocument = EndpointReferenceDocument.Factory.newInstance();
+ EndpointReferenceType endpointReferenceType = endpointReferenceDocument.addNewEndpointReference();//temporary
+ AttributedURI attributedURI = endpointReferenceType.addNewAddress();
+ attributedURI.setStringValue(InteropConstants.SERVICES_URL + "/" + InteropConstants.BLACKBERRY_SERVICE_NAME);
+ resourceProperty.add(endpointReferenceDocument);
+ resourceProperty.addChangeListener(mowsIdentificationCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.ENDPOINTDESCRIPTIONS);
+ EndpointDescriptionsDocument endpointDescriptionsDocument = EndpointDescriptionsDocument.Factory.newInstance();
+ EndpointDescriptionsDocument.EndpointDescriptions endpointDescriptions = endpointDescriptionsDocument.addNewEndpointDescriptions();
+ endpointDescriptions.addDescription(InteropConstants.SERVICES_URL + "/" + InteropConstants.BLACKBERRY_SERVICE_NAME + "?wsdl");
+ resourceProperty.add(endpointDescriptionsDocument);
+ resourceProperty.addChangeListener(mowsIdentificationCapability);
+
+ /*----------------- MOWS Metrics props -----------------*/
+
+ Calendar resetAt = Calendar.getInstance();
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.NUMBEROFREQUESTS);
+ NumberOfRequestsDocument numberOfRequestsDocument = NumberOfRequestsDocument.Factory.newInstance();
+ IntegerCounter integerCounter = numberOfRequestsDocument.addNewNumberOfRequests();
+ integerCounter.setBigIntegerValue(BigInteger.valueOf(120L));
+ integerCounter.setResetAt(resetAt);
+ resourceProperty.add(numberOfRequestsDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.NUMBEROFSUCCESSFULREQUESTS);
+ NumberOfSuccessfulRequestsDocument numberOfSuccessfulRequestsDocument = NumberOfSuccessfulRequestsDocument.Factory.newInstance();
+ IntegerCounter successIntegerCounter = numberOfSuccessfulRequestsDocument.addNewNumberOfSuccessfulRequests();
+ successIntegerCounter.setBigIntegerValue(BigInteger.valueOf(90L));
+ successIntegerCounter.setResetAt(resetAt);
+ resourceProperty.add(numberOfSuccessfulRequestsDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.NUMBEROFFAILEDREQUESTS);
+ NumberOfFailedRequestsDocument numberOfFailedRequestsDocument = NumberOfFailedRequestsDocument.Factory.newInstance();
+ IntegerCounter failedIntegerCounter = numberOfFailedRequestsDocument.addNewNumberOfFailedRequests();
+ failedIntegerCounter.setBigIntegerValue(BigInteger.valueOf(30L));
+ failedIntegerCounter.setResetAt(resetAt);
+ resourceProperty.add(numberOfFailedRequestsDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.SERVICETIME);
+ ServiceTimeDocument serviceTimeDocument = ServiceTimeDocument.Factory.newInstance();
+ DurationMetric serviceTimeMetric = serviceTimeDocument.addNewServiceTime();
+ GDurationBuilder builder = new GDurationBuilder(+1, 1, 2, 3, 4, 5, 6, new BigDecimal("0.789"));
+ serviceTimeMetric.setGDurationValue(builder.toGDuration());
+ serviceTimeMetric.setDuration(builder.toGDuration());
+ resourceProperty.add(serviceTimeDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.MAXRESPONSETIME);
+ MaxResponseTimeDocument maxResponseTimeDocument = MaxResponseTimeDocument.Factory.newInstance();
+ DurationMetric maxRespDurationMetric = maxResponseTimeDocument.addNewMaxResponseTime();
+ maxRespDurationMetric.setGDurationValue(builder.toGDuration());
+ maxRespDurationMetric.setDuration(builder.toGDuration());
+ resourceProperty.add(maxResponseTimeDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+
+ resourceProperty = resourcePropertySet.get(WeatherstationPropertyQNames.LASTRESPONSETIME);
+ LastResponseTimeDocument lastResponseTimeDocument = LastResponseTimeDocument.Factory.newInstance();
+ DurationMetric lastRespDurationMetric = lastResponseTimeDocument.addNewLastResponseTime();
+ lastRespDurationMetric.setGDurationValue(builder.toGDuration());
+ lastRespDurationMetric.setDuration(builder.toGDuration());
+ resourceProperty.add(lastResponseTimeDocument);
+ resourceProperty.addChangeListener(mowsMetricsCapability);
+ }
+ catch (Exception e)
+ {
+ throw new javax.xml.rpc.JAXRPCException("There was a problem in initializing your resource properties. Please check your init() method. Cause: " + e.getLocalizedMessage());
+ }
+ // Resource Property {http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd}FixedTopicSet is implemented by the framework.
+ // Resource Property {http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd}Topic is implemented by the framework.
+ // Resource Property {http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd}TopicExpressionDialects is implemented by the framework.
+
+ /**
+ * 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.
+ */
+ try
+ {
+ org.apache.ws.notification.topics.util.TopicUtils.addResourcePropertyValueChangeTopics(getResourcePropertySet(), getTopicSpaceSet());
+ }
+ catch (Exception e)
+ {
+ throw new javax.xml.rpc.JAXRPCException("Unable to init the ResourceProperty Changed topics. Cause: " + e.getLocalizedMessage(), e);
+ }
+
+ /**
+ * Initializes the Topic, TopicExpressionDialects and FixedTopicSet resource properties
+ *
+ * </br>
+ * <strong>NOTE this MUST be called last in the Resource.init() method to ensure all topics get registered</strong>
+ * </br>
+ * FixedTopicSet will be set based on the value returned from the {@see TopicSpaceSet#isFixed()} method.
+ * </br>
+ * Topic will have all root topics in the TopicSpaceSet, set to Simple dialect AND all child topics set ot
+ * Concrete dialect.
+ * </br>
+ *
+ * TopicExpressionDialects will be set to the engine's known Topic Dialects acquired from the TopicExpressionEngine
+ *
+ * @param topicSpaceSet
+ * @param propSet
+ */
+ org.apache.ws.notification.topics.util.TopicUtils.initNotificationProducerProperties(getTopicSpaceSet(), getResourcePropertySet());
+ }
+
+ public void setFCCID(FCCIDDocument fccidDocument)
+ {
+ ResourceProperty resourceProperty = getResourcePropertySet().get(WeatherstationPropertyQNames.FCCID);
+ resourceProperty.add(fccidDocument);
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationService.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationService.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationService.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationService.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,43 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import org.apache.ws.resource.ResourceContext;
+
+/**
+ * This class should be generated ONCE (and not overwritten) to maintain user-added code.
+ * If there is a change to the WSDL, then the generated implemented interfaces
+ * (representing the "base" portTypes) will change, thus showing a compile error to the
+ * user.
+ * <p/>
+ * NOTE: This class is generated. However, it will not be overwritten by subsequent
+ * calls to the code generator.
+ */
+public class WeatherstationService
+ extends AbstractWeatherstationService
+ implements WeatherstationCustomOperationsPortType
+{
+
+ private ResourceContext m_resourceContext;
+
+ /**
+ * Creates a new {@link WeatherstationService } object.
+ *
+ * @param resourceContext DOCUMENT_ME
+ */
+ public WeatherstationService(ResourceContext resourceContext)
+ {
+ m_resourceContext = resourceContext;
+ init();
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public ResourceContext getResourceContext()
+ {
+ return m_resourceContext;
+ }
+
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_deploy.wsdd
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_deploy.wsdd?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_deploy.wsdd (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_deploy.wsdd Thu Jul 21 09:37:14 2005
@@ -0,0 +1,26 @@
+<?xml version="1.0"?>
+
+<deployment xmlns="http://xml.apache.org/axis/wsdd/"
+ xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
+
+ <service name="weatherstation" provider="java:WSRF" style="document" use="literal">
+
+ <wsdlFile>/wsdl/weatherstation.wsdl</wsdlFile>
+
+ <requestFlow>
+ <handler type="java:org.apache.axis.handlers.JAXRPCHandler">
+ <parameter name="className" value="org.apache.axis.message.addressing.handler.AxisServerSideAddressingHandler" />
+ <parameter name="referencePropertyNames" value="*" />
+ </handler>
+ </requestFlow>
+
+ <responseFlow>
+ <handler type="java:org.apache.axis.handlers.JAXRPCHandler">
+ <parameter name="className" value="org.apache.axis.message.addressing.handler.AxisServerSideAddressingHandler" />
+ <parameter name="referencePropertyNames" value="*" />
+ </handler>
+ </responseFlow>
+
+ </service>
+
+</deployment>
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_jndi-config.xml
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_jndi-config.xml?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_jndi-config.xml (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/Weatherstation_jndi-config.xml Thu Jul 21 09:37:14 2005
@@ -0,0 +1,30 @@
+<?xml version="1.0"?>
+
+<jndiConfig xmlns="http://www.apache.org/wsfx/wsrf/jndi/config">
+
+ <service name="weatherstation">
+ <resource name="home" type="org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationHome">
+ <resourceParams>
+ <parameter>
+ <name>serviceClassName</name>
+ <value>org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationService</value>
+ </parameter>
+ <parameter>
+ <name>resourceClassName</name>
+ <value>org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationResource</value>
+ </parameter>
+ <parameter>
+ <name>wsdlTargetNamespace</name>
+ <value>http://everest-weather.org/wsdm/samples/2005/04/schema</value>
+ </parameter>
+
+ <parameter>
+ <name>resourceKeyName</name>
+ <value>{http://everest-weather.org/wsdm/samples/2005/04/schema}ResourceID</value>
+ </parameter>
+ </resourceParams>
+ </resource>
+ </service>
+
+</jndiConfig>
+
Added: webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,217 @@
+/*=============================================================================*
+ * Copyright 2005 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.muws.interop.client;
+
+import org.apache.ws.muws.v1_0.MuwsConstants;
+import org.apache.ws.muws.v1_0.capability.IdentityCapability;
+import org.apache.ws.muws.v1_0.capability.ManageabilityCharacteristicsCapability;
+import org.apache.ws.muws.v1_0.capability.OperationalStatusCapability;
+import org.apache.ws.notification.base.v2004_06.BaseNotificationConstants;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.ws.util.jndi.XmlBeanJndiUtils;
+import org.apache.ws.util.test.PortListen;
+import org.apache.ws.util.test.axis.AbstractOneAxisTestCase;
+import org.apache.xmlbeans.XmlAnyURI;
+import org.apache.xmlbeans.XmlError;
+import org.apache.xmlbeans.XmlException;
+import org.apache.xmlbeans.XmlObject;
+import org.apache.xmlbeans.XmlOptions;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.OperationalStatusDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.NotificationMessageHolderType;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.NotifyDocument;
+import org.xmlsoap.schemas.soap.envelope.Body;
+import org.xmlsoap.schemas.soap.envelope.EnvelopeDocument;
+import org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceDocument;
+
+import javax.xml.namespace.QName;
+import java.net.InetAddress;
+import java.net.URL;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * TODO
+ */
+public abstract class AbstractWsdmInteropTestCase extends AbstractOneAxisTestCase
+{
+
+ protected static final int NOTIF_LISTENER_TIMEOUT = 20000;
+ protected static final int NOTIF_LISTENER_PORT = 9101;
+ protected static String s_consumerURL;
+
+ private static final boolean RUN_AXIS_SERVER = Boolean.getBoolean( "runAxis" );
+ static final boolean DEBUG = true;//Boolean.getBoolean( "debug" );
+
+ public AbstractWsdmInteropTestCase()
+ {
+ super( RUN_AXIS_SERVER );
+ }
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+ s_consumerURL = "http://" + InetAddress.getLocalHost().getHostAddress() + ":" + NOTIF_LISTENER_PORT + "/";
+ if ( RUN_AXIS_SERVER )
+ {
+ //init jndi from config
+ XmlBeanJndiUtils.initializeFromInputStream( Thread.currentThread().getContextClassLoader()
+ .getResourceAsStream( XmlBeanJndiUtils.JNDI_CONFIG_FILENAME ) );
+ }
+ }
+
+ protected void performMuwsIdentityCharacteristicsAct( ResourceStub resource ) throws FaultException
+ {
+ XmlObject idPropElem = getSingleProperty( resource, IdentityCapability.PROP_NAME_RESOURCE_ID );
+ assertTrue( idPropElem instanceof XmlAnyURI );
+ XmlObject[] capabilityElems = resource.getResourceProperty(
+ ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, IdentityCapability.URI );
+ }
+
+ protected void performMuwsStatusAct( ResourceStub resource ) throws FaultException
+ {
+ XmlObject[] capabilityPropElems = resource.getResourceProperty(
+ ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityPropElems, OperationalStatusCapability.URI );
+ XmlObject[] statusPropElems = resource.getResourceProperty(
+ OperationalStatusCapability.PROP_NAME_OPERATIONAL_STATUS );
+ assertEquals( 1, statusPropElems.length );
+ assertTrue( statusPropElems[0] instanceof OperationalStatusDocument.OperationalStatus );
+ }
+
+ protected XmlObject getSingleProperty( ResourceStub resource, QName propName )
+ throws FaultException
+ {
+ XmlObject[] propElems = resource.getResourceProperty( propName );
+ assertEquals(
+ "Incorrect number of " + propName.getPrefix() + ":" + propName.getLocalPart() + " property elements -",
+ 1, propElems.length );
+ return propElems[0];
+ }
+
+ protected void setSingleProperty( ResourceStub resource, XmlObject propElem )
+ throws FaultException
+ {
+ resource.updateResourceProperty( new XmlObject[]{propElem} );
+ }
+
+ protected void assertContainsURI( XmlObject[] capabilityPropElems, String uri )
+ {
+ boolean result = false;
+ for ( int i = 0; i < capabilityPropElems.length; i++ )
+ {
+ XmlAnyURI capabilityElem = (XmlAnyURI) capabilityPropElems[i];
+ if ( capabilityElem.getStringValue().equals( uri ) )
+ {
+ result = true;
+ break;
+ }
+ }
+ assertTrue( "List of manageability capabilities does not include the URI: " + uri, result );
+ }
+
+ /**
+ * Reads a wsa03:EndpointReference XML document from the specified URL.
+ *
+ * @param url
+ *
+ * @return
+ *
+ * @throws Exception
+ */
+ protected EndpointReferenceDocument getEndpointReference( URL url ) throws Exception
+ {
+ return (EndpointReferenceDocument) XmlObject.Factory.parse( url );
+ }
+
+ protected ManagementEventType waitForManagementEvent( PortListen notifListener ) throws XmlException
+ {
+ String incomingMsg = notifListener.waitForIncomingMessage();
+ assertTrue( incomingMsg, incomingMsg.indexOf( "ERROR" ) == -1 );
+
+ //get envelope
+ XmlObject xmlObject = XmlObject.Factory.parse( incomingMsg );
+ assertTrue( "The returned message was not a SOAP Envelope.", xmlObject instanceof EnvelopeDocument );
+ EnvelopeDocument envelope = (EnvelopeDocument) xmlObject;
+ Body body = envelope.getEnvelope().getBody();
+
+ XmlObject mgmtEventElem = null;
+ if ( ResourceStub.USE_WRAPPED_NOTIFICATIONS ) //wrapped
+ {
+ //get notify
+ XmlObject bodyElems[] = XmlBeanUtils.getChildElements( body,
+ new QName( BaseNotificationConstants.NSURI_WSNT_SCHEMA, "Notify" ) );
+ assertEquals( "The SOAP Body does not contain exactly one wsnt:Notify element.", 1, bodyElems.length );
+ XmlObject notifyDoc = bodyElems[0];
+ assertTrue( "The SOAP Body does not contain a wrapped notification with a Notify element.",
+ notifyDoc instanceof NotifyDocument.Notify );
+ NotifyDocument.Notify notify = (NotifyDocument.Notify) notifyDoc;
+
+ //get contained management event
+ NotificationMessageHolderType notificationMessageType = notify.getNotificationMessageArray( 0 );
+ XmlObject message = notificationMessageType.getMessage();
+
+ XmlObject mgmtEventElems[] = XmlBeanUtils.getChildElements( message,
+ new QName( MuwsConstants.NSURI_MUWS_PART1_SCHEMA, "ManagementEvent" ) );
+ assertEquals( "The Notify element does not contain exactly one muws-p1-xs:ManagementEvent element.", 1,
+ mgmtEventElems.length );
+ mgmtEventElem = mgmtEventElems[0];
+ assertTrue( "The Notify element does not contain a ManagementEvent.",
+ mgmtEventElem instanceof ManagementEventType );
+ }
+ else //unwrapped
+ {
+ XmlObject mgmtEventElems[] = XmlBeanUtils.getChildElements( body,
+ new QName( MuwsConstants.NSURI_MUWS_PART1_SCHEMA, "ManagementEvent" ) );
+ assertEquals( "The SOAP Body does not contain exactly one muws-p1-xs:ManagementEvent element.", 1,
+ mgmtEventElems.length );
+ mgmtEventElem = mgmtEventElems[0];
+ assertTrue( "The SOAP Body did not contain an unwrapped ManagementEvent.",
+ mgmtEventElem instanceof ManagementEventType );
+ }
+ ManagementEventType mgmtEvent = (ManagementEventType) mgmtEventElem;
+ return mgmtEvent;
+ }
+
+ protected static boolean validate( XmlObject xBean )
+ {
+ // Create an XmlOptions instance and set the error listener.
+ XmlOptions validateOptions = new XmlOptions();
+ List errorList = new ArrayList();
+ validateOptions.setErrorListener( errorList );
+
+ // Validate the XML.
+ boolean isValid = xBean.validate( validateOptions );
+
+ // If the XML isn't valid, loop through the listener's contents,
+ // printing contained messages.
+ if ( !isValid )
+ {
+ for ( int i = 0; i < errorList.size(); i++ )
+ {
+ XmlError error = (XmlError) errorList.get( i );
+
+ System.out.println( "\n" );
+ System.out.println( "Message: " + error.getMessage() + "\n" );
+ System.out.println( "Location of invalid XML: " +
+ error.getCursorLocation().xmlText() + "\n" );
+ }
+ }
+ return isValid;
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/FaultException.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/FaultException.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/FaultException.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/FaultException.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,30 @@
+/*=============================================================================*
+ * Copyright 2005 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.muws.interop.client;
+
+/**
+ * TODO
+ */
+public class FaultException extends Exception
+{
+
+ public FaultException( String message )
+ {
+ super( message );
+ }
+
+}
+
Added: webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ResourceStub.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ResourceStub.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ResourceStub.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ResourceStub.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,188 @@
+/*=============================================================================*
+ * Copyright 2005 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.muws.interop.client;
+
+import org.apache.ws.addressing.EndpointReference;
+import org.apache.ws.addressing.XmlBeansEndpointReference;
+import org.apache.ws.notification.topics.v2004_06.TopicsConstants;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.ws.util.soap.SoapClient;
+import org.apache.ws.XmlObjectWrapper;
+import org.apache.xmlbeans.XmlObject;
+import org.apache.axis.message.addressing.Constants;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.TopicExpressionType;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyResponseDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.SetResourcePropertiesDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.SetResourcePropertiesResponseDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.UpdateType;
+import org.xmlsoap.schemas.soap.envelope.Envelope;
+import org.xmlsoap.schemas.soap.envelope.EnvelopeDocument;
+import org.xmlsoap.schemas.soap.envelope.Header;
+
+import javax.xml.namespace.QName;
+import java.net.URI;
+import java.net.URL;
+import java.util.Calendar;
+
+/**
+ * TODO
+ */
+public class ResourceStub
+{
+
+ private EndpointReference m_epr;
+
+ public static boolean USE_WRAPPED_NOTIFICATIONS = Boolean.valueOf(System.getProperty("wrapped_notifications", "true")).booleanValue();
+
+ public ResourceStub( EndpointReference epr )
+ {
+ m_epr = epr;
+ }
+
+ public XmlObject[] getResourceProperty( QName propName ) throws FaultException
+ {
+ GetResourcePropertyDocument requestDoc = GetResourcePropertyDocument.Factory.newInstance();
+ requestDoc.setGetResourceProperty( propName );
+ XmlObject response = sendRequest( requestDoc, "http://xyz.com/action/GetResourceProperty" );
+ if ( ! ( response instanceof GetResourcePropertyResponseDocument.GetResourcePropertyResponse ) )
+ {
+ throw new FaultException( response.toString() );
+ }
+ return XmlBeanUtils.getChildElements( response );
+ }
+
+ public void updateResourceProperty( XmlObject[] propElems ) throws FaultException
+ {
+ SetResourcePropertiesDocument requestDoc = SetResourcePropertiesDocument.Factory.newInstance();
+ SetResourcePropertiesDocument.SetResourceProperties setResourceProperties = requestDoc.addNewSetResourceProperties();
+ UpdateType updateType = setResourceProperties.addNewUpdate();
+ for ( int i = 0; i < propElems.length; i++ )
+ {
+ XmlBeanUtils.addChildElement( updateType, propElems[i] );
+ }
+ XmlObject response = sendRequest( requestDoc, "http://xyz.com/action/SetResourceProperties" );
+ if ( ! ( response instanceof SetResourcePropertiesResponseDocument.SetResourcePropertiesResponse ) )
+ {
+ throw new FaultException( response.toString() );
+ }
+ }
+
+ public EndpointReference subscribe( String consumerURL, QName topic ) throws FaultException
+ {
+ SubscribeDocument requestDoc = SubscribeDocument.Factory.newInstance();
+ SubscribeDocument.Subscribe subscribe = requestDoc.addNewSubscribe();
+ subscribe.setUseNotify(USE_WRAPPED_NOTIFICATIONS);
+ Calendar instance = Calendar.getInstance();
+ instance.setTimeInMillis(instance.getTimeInMillis() + 20000);
+ subscribe.setInitialTerminationTime( instance );
+ org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceType consumerRef = subscribe.addNewConsumerReference();
+ org.xmlsoap.schemas.ws.x2003.x03.addressing.AttributedURI address = consumerRef.addNewAddress();
+ address.setStringValue( consumerURL );
+ TopicExpressionType topicExpr = subscribe.addNewTopicExpression();
+ topicExpr.setDialect( TopicsConstants.TOPIC_EXPR_DIALECT_SIMPLE );
+ XmlBeanUtils.setValueAsQName( topicExpr, topic );
+ XmlObject response = sendRequest( requestDoc, "http://xyz.com/action/Subscribe" );
+ if ( ! ( response instanceof SubscribeResponseDocument.SubscribeResponse ) )
+ {
+ throw new FaultException( response.toString() );
+ }
+ SubscribeResponseDocument.SubscribeResponse subscribeResponse = (SubscribeResponseDocument.SubscribeResponse) response;
+ return new XmlBeansEndpointReference( subscribeResponse.getSubscriptionReference() );
+ }
+
+ private EnvelopeDocument createEnvelope()
+ {
+ EnvelopeDocument envelopeDoc = EnvelopeDocument.Factory.newInstance();
+ Envelope envelope = envelopeDoc.addNewEnvelope();
+ envelope.addNewHeader();
+ envelope.addNewBody();
+ return envelopeDoc;
+ }
+
+ private XmlObject sendRequest( XmlObject requestDoc, String action )
+ {
+ EnvelopeDocument requestEnvelopeDoc = createEnvelope();
+ Envelope requestEnvelope = requestEnvelopeDoc.getEnvelope();
+ addAddressingHeaders( requestEnvelope.getHeader(), action );
+ XmlBeanUtils.addChildElement( requestEnvelope.getBody(), requestDoc );
+ try
+ {
+ URL endpointURL = new URL( m_epr.getAddress() );
+ URI actionURI = new URI( action );
+ if ( AbstractWsdmInteropTestCase.DEBUG ) { System.out.println( "Sending request: \n" + requestEnvelopeDoc ); }
+ String response = SoapClient.sendRequest( endpointURL, requestEnvelopeDoc.newInputStream(), actionURI );
+ EnvelopeDocument responseEnvelopeDoc = (EnvelopeDocument) XmlObject.Factory.parse( response );
+ if ( AbstractWsdmInteropTestCase.DEBUG ) { System.out.println( "Received response: \n" + responseEnvelopeDoc ); }
+ Envelope responseEnvelope = responseEnvelopeDoc.getEnvelope();
+ XmlObject[] responseBodyElems = XmlBeanUtils.getChildElements( responseEnvelope.getBody() );
+ if ( responseBodyElems.length == 0 )
+ {
+ return null;
+ }
+ else
+ {
+ return responseBodyElems[0];
+ }
+ }
+ catch ( Exception e )
+ {
+ throw new RuntimeException( e );
+ }
+ }
+
+ private void addAddressingHeaders( Header header, String action )
+ {
+ XmlObject eprXBean = ((XmlObjectWrapper)m_epr).getXmlObject();
+ XmlObject toElem;
+ XmlObject actionElem;
+ if ( eprXBean.schemaType().getName().getNamespaceURI().equals( Constants.NS_URI_ADDRESSING_2003_03 ) )
+ {
+ org.xmlsoap.schemas.ws.x2003.x03.addressing.ToDocument toDoc = org.xmlsoap.schemas.ws.x2003.x03.addressing.ToDocument.Factory.newInstance();
+ org.xmlsoap.schemas.ws.x2003.x03.addressing.AttributedURI attributedURI = toDoc.addNewTo();
+ attributedURI.setStringValue(m_epr.getAddress());
+ toElem = toDoc;
+ org.xmlsoap.schemas.ws.x2003.x03.addressing.ActionDocument actionDoc = org.xmlsoap.schemas.ws.x2003.x03.addressing.ActionDocument.Factory.newInstance();
+ org.xmlsoap.schemas.ws.x2003.x03.addressing.AttributedURI actionType = actionDoc.addNewAction();
+ actionType.setStringValue( action );
+ actionElem = actionDoc;
+ }
+ else
+ {
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.ToDocument toDoc = org.xmlsoap.schemas.ws.x2004.x08.addressing.ToDocument.Factory.newInstance();
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.AttributedURI attributedURI = toDoc.addNewTo();
+ attributedURI.setStringValue(m_epr.getAddress());
+ toElem = toDoc;
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.ActionDocument actionDoc = org.xmlsoap.schemas.ws.x2004.x08.addressing.ActionDocument.Factory.newInstance();
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.AttributedURI actionType = actionDoc.addNewAction();
+ actionType.setStringValue( action );
+ actionElem = actionDoc;
+ }
+ XmlBeanUtils.addChildElement( header, toElem );
+ XmlBeanUtils.addChildElement( header, actionElem );
+ if (m_epr.getReferenceProperties() != null)
+ {
+ XmlObject[] refPropElems = (XmlObject[]) m_epr.getReferenceProperties();
+ for (int i = 0; i < refPropElems.length; i++)
+ {
+ XmlBeanUtils.addChildElement(header, refPropElems[i]);
+ }
+ }
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServerMgmtTestCase.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServerMgmtTestCase.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServerMgmtTestCase.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServerMgmtTestCase.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,113 @@
+/*=============================================================================*
+ * Copyright 2005 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.muws.interop.client;
+
+import com.dell.wsdm.demos.interop.x2005.x04.AttentionLedOnDocument;
+import com.dell.wsdm.demos.interop.x2005.x04.IpmiserverPropertyQNames;
+import org.apache.ws.addressing.XmlBeansEndpointReference;
+import org.apache.ws.muws.v1_0.capability.ConfigurationCapability;
+import org.apache.ws.muws.v1_0.capability.ManageabilityCharacteristicsCapability;
+import org.apache.ws.muws.v1_0.capability.OperationalStatusCapability;
+import org.apache.xmlbeans.XmlBoolean;
+import org.apache.xmlbeans.XmlObject;
+import org.apache.xmlbeans.XmlString;
+import org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceDocument;
+
+import java.net.URL;
+
+/**
+ * A test case containing a test for each act in the "Server Management"
+ * playbook, as defined in the WSDM 1.0 interop scenarios doc.
+ *
+ * @author Ian Springer
+ */
+public class ServerMgmtTestCase extends AbstractWsdmInteropTestCase
+{
+
+ public static final String SYSPROP_IPMI_SERVER_EPR = "ipmi_server.epr";
+
+ private static final String DEFAULT_IPMI_SERVER_EPR = "http://cvs.apache.org/~ips/interop/ipmi_server-epr.xml";
+ private static final String IPMI_SERVER_EPR = System.getProperty( SYSPROP_IPMI_SERVER_EPR, DEFAULT_IPMI_SERVER_EPR );
+
+ private static final String NSURI_IPMI_SERVER = "http://dell.com/wsdm/demos/interop/2005/04";
+ private static final String CAPABILITY_URI_SERVER_CONFIGURATION = NSURI_IPMI_SERVER + "/ServerConfiguration";
+ private static final String CAPABILITY_URI_SERVER_CHASSIS_CONFIGURATION = NSURI_IPMI_SERVER + "/ServerChassisConfiguration";
+ private static final String CAPABILITY_URI_SERVER_ALERT_STATUS = NSURI_IPMI_SERVER + "/ServerAlertStatus";
+
+ private ResourceStub m_resource;
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+ EndpointReferenceDocument ipmiServerEprDoc = getEndpointReference( new URL( IPMI_SERVER_EPR ) );
+ if ( DEBUG ) { System.out.println( "*** Using IPMI Server EPR:\n" + ipmiServerEprDoc ); }
+ m_resource = new ResourceStub( new XmlBeansEndpointReference(ipmiServerEprDoc.getEndpointReference()) );
+ }
+
+ public void testMuwsIdentityCharacteristics() throws FaultException
+ {
+ performMuwsIdentityCharacteristicsAct( m_resource );
+ }
+
+ public void testServerAssets() throws FaultException
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty(
+ ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, ConfigurationCapability.URI );
+ assertContainsURI( capabilityElems, CAPABILITY_URI_SERVER_CONFIGURATION );
+ XmlObject serialNumberPropElem = getSingleProperty( m_resource, IpmiserverPropertyQNames.SERIALNUMBER );
+ assertTrue( serialNumberPropElem instanceof XmlString );
+ System.out.println( "Value of svr:SerialNumber property is: " + ((XmlString)serialNumberPropElem).getStringValue() );
+ System.out.println( "*** Please verify that this result matches the known manufacturer's serial number." );
+ XmlObject modelNamePropElem = getSingleProperty( m_resource, IpmiserverPropertyQNames.MODELNAME );
+ assertTrue( modelNamePropElem instanceof XmlString );
+ XmlObject ipNamePropElem = getSingleProperty( m_resource, IpmiserverPropertyQNames.IPNAME );
+ assertTrue( ipNamePropElem instanceof XmlString );
+ XmlObject sysContactPropElem = getSingleProperty( m_resource, IpmiserverPropertyQNames.SYSCONTACT );
+ assertTrue( sysContactPropElem instanceof XmlString );
+ }
+
+ public void testServerAlert() throws FaultException
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty(
+ ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, OperationalStatusCapability.URI );
+ assertContainsURI( capabilityElems, CAPABILITY_URI_SERVER_ALERT_STATUS );
+ AttentionLedOnDocument attentionLedOnDoc = AttentionLedOnDocument.Factory.newInstance();
+ attentionLedOnDoc.setAttentionLedOn( true );
+ setSingleProperty( m_resource, attentionLedOnDoc );
+ System.out.println( "svr:AttentionLedOn property has been set to true." );
+ System.out.println( "*** Please verify that the front panel attention LED blinks for approximately ten seconds." );
+ }
+
+ public void testServerChassisIntrusionDetection() throws FaultException
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty(
+ ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, ConfigurationCapability.URI );
+ assertContainsURI( capabilityElems, CAPABILITY_URI_SERVER_CHASSIS_CONFIGURATION );
+ XmlObject coverOpenPropElem = getSingleProperty( m_resource, IpmiserverPropertyQNames.COVEROPEN );
+ assertTrue( coverOpenPropElem instanceof XmlBoolean );
+ System.out.println( "Value of svr:CoverOpen property is: " + ((XmlBoolean)coverOpenPropElem).getStringValue() );
+ System.out.println( "*** Please verify that this result matches the current visible state of the front panel bezel and other interlocked covers of the server." );
+ }
+
+ public void testMuwsStatus() throws FaultException
+ {
+ performMuwsStatusAct( m_resource );
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,190 @@
+/*=============================================================================*
+ * Copyright 2005 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.muws.interop.client;
+
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.ws.util.soap.SoapClient;
+import org.apache.ws.resource.impl.SimpleTypeResourceKey;
+import org.apache.ws.resource.example.InteropConstants;
+import org.apache.xmlbeans.XmlObject;
+import org.apache.xmlbeans.XmlException;
+import org.everest.GetCurrentTemperatureDocument;
+import org.everest.GetCurrentTemperatureResponseDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.GetManageabilityReferencesDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.GetManageabilityReferencesResponseDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.QueryRelationshipsByTypeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.QueryRelationshipsByTypeResponseDocument;
+import org.xmlsoap.schemas.soap.envelope.Envelope;
+import org.xmlsoap.schemas.soap.envelope.EnvelopeDocument;
+import org.xmlsoap.schemas.soap.envelope.Header;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.EndpointReferenceType;
+import org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationPropertyQNames;
+
+import javax.xml.namespace.QName;
+import javax.xml.soap.SOAPEFrom muse-dev-return-1027-apmail-ws-muse-dev-archive=ws.apache.org@ws.apache.org Thu Jul 21 16:39:24 2005
Return-Path: <mu...@ws.apache.org>
Delivered-To: apmail-ws-muse-dev-archive@www.apache.org
Received: (qmail 80097 invoked from network); 21 Jul 2005 16:39:23 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199)
by minotaur.apache.org with SMTP; 21 Jul 2005 16:39:23 -0000
Received: (qmail 68401 invoked by uid 500); 21 Jul 2005 16:39:21 -0000
Delivered-To: apmail-ws-muse-dev-archive@ws.apache.org
Received: (qmail 68344 invoked by uid 500); 21 Jul 2005 16:39:21 -0000
Mailing-List: contact muse-dev-help@ws.apache.org; run by ezmlm
Precedence: bulk
list-help: <ma...@ws.apache.org>
list-unsubscribe: <ma...@ws.apache.org>
List-Post: <ma...@ws.apache.org>
Reply-To: muse-dev@ws.apache.org
List-Id: <muse-dev.ws.apache.org>
Delivered-To: mailing list muse-dev@ws.apache.org
Received: (qmlement;
+import java.net.URI;
+import java.net.URL;
+import java.net.MalformedURLException;
+
+/**
+ * TODO
+ */
+public class ServiceStub
+{
+
+ private URL m_url;
+
+ public ServiceStub( URL url )
+ {
+ m_url = url;
+ }
+
+ public EndpointReferenceType[] getManageabilityReferences() throws FaultException
+ {
+ GetManageabilityReferencesDocument requestDoc = GetManageabilityReferencesDocument.Factory.newInstance();
+ requestDoc.addNewGetManageabilityReferences();
+ XmlObject response = sendRequest( requestDoc, "http://xyz.com/action/GetManageabilityReferences", m_url);
+ if ( ! ( response instanceof GetManageabilityReferencesResponseDocument.GetManageabilityReferencesResponse ) )
+ {
+ throw new FaultException( response.toString() );
+ }
+ return ((GetManageabilityReferencesResponseDocument.GetManageabilityReferencesResponse)response).getManageabilityEndpointReferenceArray();
+ }
+
+ publiail 68247 invoked by uid 500); 21 Jul 2005 16:39:20 -0000
Delivered-To: apmail-ws-muse-cvs@ws.apache.org
Received: (qmail 68225 invoked by uid 99); 21 Jul 2005 16:39:19 -0000
X-ASF-Spam-Status: No, hits=-9.8 required=10.0
tests=ALL_TRUSTED,NO_REAL_NAME
X-Spam-Check-By: apache.org
Received: from [209.237.227.194] (HELO minotaur.apache.org) (209.237.227.194)
by apache.org (qpsmtpd/0.29) with SMTP; Thu, 21 Jul 2005 09:38:55 -0700
Received: (qmail 79434 invoked by uid 65534); 21 Jul 2005 16:38:50 -0000
Message-ID: <20...@minotaur.apache.org>
Content-Type: text/plain; charset="utf-8"
MIME-Version: 1.0
Content-Transfer-Encoding: 7bit
Subject: svn commit: r220138 [9/11] - in
/webservices/muse/trunk/src/examples/interop: ./ lib/ src/ src/.xmlbeans/
src/.xmlbeans/src/ src/.xmlbeans/src/com/ src/.xmlbeans/src/com/dell/
src/.xmlbeans/src/com/dell/wsdm/ src/.xmlbeans/src/com/dell/wsdm/demos/
src/...
Date: Thu, 21 Jul 2005 16:37:32 -0000
To: muse-cvs@ws.apache.org
From: jruzzi@apache.org
X-Mac double getCurrentTemperature() throws FaultException
+ {
+ GetCurrentTemperatureDocument requestDoc = GetCurrentTemperatureDocument.Factory.newInstance();
+ GetCurrentTemperatureDocument.GetCurrentTemperature getCurrentTemperature = requestDoc.addNewGetCurrentTemperature();
+ getCurrentTemperature.setAltitude( 643.0 );
+ XmlObject response = sendRequest( requestDoc, "http://xyz.com/action/GetCurrentTemperature", m_url);
+ if ( ! ( response instanceof GetCurrentTemperatureResponseDocument.GetCurrentTemperatureResponse ) )
+ {
+ throw new FaultException( response.toString() );
+ }
+ return ((GetCurrentTemperatureResponseDocument.GetCurrentTemperatureResponse)response).getGetCurrentTemperatureResult();
+ }
+
+ public RelationshipType[] queryRelationshipsByType( QName type ) throws FaultException, MalformedURLException, XmlException
+ {
+ QueryRelationshipsByTypeDocument requestDoc = QueryRelationshipsByTypeDociler: svnmailer-1.0.2
X-Virus-Checked: Checked by ClamAV on apache.org
X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/AbstractBlackberryService.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/AbstractBlackberryService.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/AbstractBlackberryService.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/AbstractBlackberryService.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,130 @@
+package org.apache.ws.resource.example.blackberry;
+
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.handler.ServiceSoapMethodNameMap;
+import org.apache.ws.resoument.Factory.newInstance();
+ QueryRelationshipsByTypeDocument.QueryRelationshipsByType queryRelationshipsByType = requestDoc.addNewQueryRelationshipsByType();
+ queryRelationshipsByType.setRequestedType(type);
+ URL url = new URL(m_url,"weatherstation");
+
+ EnvelopeDocument requestEnvelopeDoc = createEnvelope();
+ Envelope requestEnvelope = requestEnvelopeDoc.getEnvelope();
+ XmlBeanUtils.addChildElement( requestEnvelope.getBody(), requestDoc );
+
+ QName qName = new QName(WeatherstationPropertyQNames.FCCID.getNamespaceURI(),"ResourceID");
+
+
+ addAddressingHeader(requestEnvelope.getHeader(), "http://xyz.com/action/QueryRelationship", url.toString(),qName,InteropConstants.WEATHERSTATION_KEY1);
+
+ XmlObject response = sendRequest( requestEnvelopeDoc, "http://xyz.com/action/QueryRelationship", url);
+ if ( ! ( response instanceof QueryRelationshipsByTypeResponseDocument.QueryRelationshipsByTypeResponse ) )
+ {
+ urce.handler.SoapMethodNameMap;
+
+import javax.xml.namespace.QName;
+
+/**
+ * This class should be generated on every "generation" against the WSDL.
+ * This will ensure it is always up-to-date with the WSDL.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public abstract class AbstractBlackberryService
+ implements org.apache.ws.resource.handler.WsrfService, org.apache.ws.resource.properties.v2004_06.porttype.SetResourcePropertiesPortType, org.apache.ws.resource.properties.v2004_06.porttype.GetResourcePropertyPortType, org.apache.ws.notification.base.v2004_06.porttype.NotificationProducerPortType
+{
+
+ public static final String TARGET_NSURI = "http://ws.apache.org/resource/example/blackberry";
+ public static final String TARGET_NSPREFIX = "blackberry";
+
+ /**
+ * DOCUMENT_ME
+ */
+ private ServiceSoapMethodNameMap m_methodNameMap;
+
+ /**
+ * DOCUMENT_ME
+ */
+ private boolean m_isInitialized;
+
+ / throw new FaultException( response.toString() );
+ }
+ return ((QueryRelationshipsByTypeResponseDocument.QueryRelationshipsByTypeResponse)response).getRelationshipArray();
+ }
+
+
+ private EnvelopeDocument createEnvelope()
+ {
+ EnvelopeDocument envelopeDoc = EnvelopeDocument.Factory.newInstance();
+ Envelope envelope = envelopeDoc.addNewEnvelope();
+ envelope.addNewHeader();
+ envelope.addNewBody();
+ return envelopeDoc;
+ }
+
+ private XmlObject sendRequest(XmlObject requestDoc, String action, URL url)
+ {
+ EnvelopeDocument requestEnvelopeDoc = createEnvelope();
+ Envelope requestEnvelope = requestEnvelopeDoc.getEnvelope();
+ XmlBeanUtils.addChildElement( requestEnvelope.getBody(), requestDoc );
+ try
+ {
+ URI actionURI = new URI( action );
+ if ( AbstractWsdmInteropTestCase.DEBUG ) { System.out.println( "Sending request: \n" + requestEnvelopeDoc ); **
+ * DOCUMENT_ME
+ *
+ * @param requestQname DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public String getMethodName(QName requestQname)
+ {
+ if (!m_isInitialized)
+ {
+ init();
+ }
+
+ return m_methodNameMap.getMethodName(requestQname);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public abstract ResourceContext getResourceContext();
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public final SoapMethodNameMap getMethodNameMap()
+ {
+ return m_methodNameMap;
+ }
+
+ /**
+ * DOCUMENT_ME
+ */
+ public void init()
+ {
+ m_methodNameMap = new ServiceSoapMethodNameMap(getResourceContext());
+ m_isInitialized = true;
+ }
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ protected final boolean isInitialized()
+ {
+ return m_isInitializ}
+ String response = SoapClient.sendRequest( url, requestEnvelopeDoc.newInputStream(), actionURI );
+ EnvelopeDocument responseEnvelopeDoc = (EnvelopeDocument) XmlObject.Factory.parse( response );
+ if ( AbstractWsdmInteropTestCase.DEBUG ) { System.out.println( "Received response: \n" + responseEnvelopeDoc ); }
+ Envelope responseEnvelope = responseEnvelopeDoc.getEnvelope();
+ XmlObject[] responseBodyElems = XmlBeanUtils.getChildElements( responseEnvelope.getBody() );
+ if ( responseBodyElems.length == 0 )
+ {
+ return null;
+ }
+ else
+ {
+ return responseBodyElems[0];
+ }
+ }
+ catch ( Exception e )
+ {
+ throw new RuntimeException( e );
+ }
+ }
+ private XmlObject sendRequest(EnvelopeDocument requestEnvelope, String action, URL url)
+ {
+
+ try
+ {
+ URI actioned;
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.SetResourcePropertiesResponseDocument setResourceProperties(org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.SetResourcePropertiesDocument requestDoc)
+ {
+ return new org.apache.ws.resource.properties.v2004_06.porttype.impl.SetResourcePropertiesPortTypeImpl(getResourceContext()).setResourceProperties(requestDoc);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyResponseDocument getResourceProperty(org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyDocument requestDoc)
+ {
+ return new org.apache.ws.resource.properties.v2004_06.porttype.impl.GetURI = new URI( action );
+ if ( AbstractWsdmInteropTestCase.DEBUG ) { System.out.println( "Sending request: \n" + requestEnvelope ); }
+ String response = SoapClient.sendRequest( url, requestEnvelope.newInputStream(), actionURI );
+ EnvelopeDocument responseEnvelopeDoc = (EnvelopeDocument) XmlObject.Factory.parse( response );
+ if ( AbstractWsdmInteropTestCase.DEBUG ) { System.out.println( "Received response: \n" + responseEnvelopeDoc ); }
+ Envelope responseEnvelope = responseEnvelopeDoc.getEnvelope();
+ XmlObject[] responseBodyElems = XmlBeanUtils.getChildElements( responseEnvelope.getBody() );
+ if ( responseBodyElems.length == 0 )
+ {
+ return null;
+ }
+ else
+ {
+ return responseBodyElems[0];
+ }
+ }
+ catch ( Exception e )
+ {
+ throw new RuntimeException( e );
+ }
+ }
+
+ privResourcePropertyPortTypeImpl(getResourceContext()).getResourceProperty(requestDoc);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeResponseDocument subscribe(org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeDocument requestDoc)
+ {
+ return new org.apache.ws.notification.base.v2004_06.porttype.impl.NotificationProducerPortTypeImpl(getResourceContext()).subscribe(requestDoc);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageResponseDocument getCurrentMessage(org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageDocument requestDoc)
+ {
+ return new org.apache.ws.notification.base.v2004_06.porttype.impate void addAddressingHeader(Header header, String action, String address, QName keyHeaderName, String weatherstationKey1)
+ {
+ XmlObject toElem;
+ XmlObject actionElem;
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.ToDocument toDoc = org.xmlsoap.schemas.ws.x2004.x08.addressing.ToDocument.Factory.newInstance();
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.AttributedURI attributedURI = toDoc.addNewTo();
+ attributedURI.setStringValue(address);
+ toElem = toDoc;
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.ActionDocument actionDoc = org.xmlsoap.schemas.ws.x2004.x08.addressing.ActionDocument.Factory.newInstance();
+ org.xmlsoap.schemas.ws.x2004.x08.addressing.AttributedURI actionType = actionDoc.addNewAction();
+ actionType.setStringValue(action);
+ actionElem = actionDoc;
+
+ XmlBeanUtils.addChildElement(header, toElem);
+ XmlBeanUtils.addChildElement(header, actionElem);
+
+
+ XmlObject resourceKeyl.NotificationProducerPortTypeImpl(getResourceContext()).getCurrentMessage(requestDoc);
+ }
+
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryCustomOperationsPortType.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryCustomOperationsPortType.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryCustomOperationsPortType.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryCustomOperationsPortType.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,12 @@
+package org.apache.ws.resource.example.blackberry;
+
+/**
+ * Custom operations portType.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ *Header = XmlBeanUtils.addChildElement(header, keyHeaderName);
+ XmlBeanUtils.setValue(resourceKeyHeader, weatherstationKey1);
+ }
+}
Added: webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/SmallDeviceMgmtTestCase.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/SmallDeviceMgmtTestCase.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/SmallDeviceMgmtTestCase.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/test/org/apache/ws/muws/interop/client/SmallDeviceMgmtTestCase.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,202 @@
+/*=============================================================================*
+ * Copyright 2005 The Apache Software Foundation
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+/
+public interface BlackberryCustomOperationsPortType
+{
+
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryHome.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryHome.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryHome.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryHome.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,120 @@
+package org.apache.ws.resource.example.blackberry;
+
+import org.apache.ws.resource.Resource;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.ResourceContextException;
+import org.apache.ws.resource.ResourceException;
+import org.apache.ws.resource.Reso * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *=============================================================================*/
+package org.apache.ws.muws.interop.client;
+
+import org.apache.ws.addressing.XmlBeansEndpointReference;
+import org.apache.ws.muws.v1_0.MuwsConstants;
+import org.apache.ws.muws.v1_0.capability.ConfigurationCapability;
+import org.apache.ws.muws.v1_0.capability.ManageabilityCharacteristicsCapability;
+import org.apache.ws.muws.v1_0.capability.MetricsCapability;
+import org.apache.ws.muws.v1_0.capability.OperationurceKey;
+import org.apache.ws.resource.ResourceUnknownException;
+import org.apache.ws.resource.impl.AbstractResourceHome;
+import org.apache.ws.addressing.EndpointReference;
+
+import javax.xml.namespace.QName;
+import java.io.Serializable;
+
+/**
+ * Home for Blackberry WS-Resources.
+ */
+public class BlackberryHome
+ extends AbstractBlackberryHome
+ implements Serializable
+{
+ /**
+ * The service endpoint name as registered with the SOAP Platform. This is useful for building EPR's. *
+ */
+ public static final QName SERVICE_NAME = javax.xml.namespace.QName.valueOf("{http://ws.apache.org/resource/example/blackberry}blackberry");
+
+ /**
+ * The management PortType associated with this resource. This is useful for building EPR's.*
+ */
+ public static final QName PORT_TYPE = javax.xml.namespace.QName.valueOf("{http://ws.apache.org/resource/example/blackberry}BlackberryPortType");
+
+ /**
+ * The WSDL Port name associated with the alStatusCapability;
+import org.apache.ws.resource.example.blackberry.BlackberryPropertyQNames;
+import org.apache.ws.resource.properties.v2004_06.ResourcePropertiesConstants;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.ws.util.test.PortListen;
+import org.apache.xmlbeans.XmlDateTime;
+import org.apache.xmlbeans.XmlObject;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.OperationalStatusDocument;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.ResourcePropertyValueChangeNotificationType;
+import org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceDocument;
+import rim.pda.DateDocument;
+import rim.pda.TimeDocument;
+import rim.pda.TotalCodeModuleSizeDocument;
+
+import javax.xml.namespace.QName;
+import java.net.URL;
+
+/**
+ * A test case containing a test for each act in the "Small Device Management"
+ * playbook, as defined in the WSDM 1.0 iresource. This is useful for building EPR's. *
+ */
+ public static final String PORT_NAME = "blackberry";
+
+ /**
+ * The name of the resource key for this resource. *
+ */
+ public static final QName RESOURCE_KEY_NAME = javax.xml.namespace.QName.valueOf("{http://ws.apache.org/resource/example/blackberry}ResourceID");
+
+ /**
+ * A NamespaceVerionHolder which maintains the QNames of Spec Wsdls
+ */
+ public static final org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl SPEC_NAMESPACE_SET = new org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl();
+ /**
+ * A constant for the JNDI Lookup name for this home. *
+ */
+ public static final String HOME_LOCATION =
+ org.apache.ws.resource.JndiConstants.CONTEXT_NAME_SERVICES + "/" + SERVICE_NAME.getLocalPart() + "/" + org.apache.ws.resource.JndiConstants.ATOMIC_NAME_HOME;
+
+ /**
+ * TODO
+ *
+ * @param resourceContext DOCUMENT_ME
+ * @return DOCUnterop scenarios doc.
+ *
+ * @author Ian Springer
+ */
+public class SmallDeviceMgmtTestCase extends AbstractWsdmInteropTestCase
+{
+
+ public static final String SYSPROP_BLACKBERRY_EPR = "blackberry.epr";
+
+ private static final String HP_BLACKBERRY_EPR = "http://cvs.apache.org/~ips/interop/blackberry-epr.xml";
+ private static final String IBM_BLACKBERRY_EPR = "http://66.57.65.244:4400/ettk/tinywsdmDemo/BBEPR/RIM2100000A";
+
+ private static final String BLACKBERRY_EPR = System.getProperty( SYSPROP_BLACKBERRY_EPR, HP_BLACKBERRY_EPR );
+
+ private static final String NSURI_BLACKBERRY = "http://pda.rim";
+ private static final String NSPREFIX_BLACKBERRY = "bbry";
+ private static final String CAPABILITY_URI_BLACKBERRY_CONFIGURATION = NSURI_BLACKBERRY + "/BlackberryConfiguration";
+ private static final String CAPABILITY_URI_BLACKBERRY_METRICS = NSURI_BLACKBERRY + "/BlackberryMetrics";
+ private static final QName PROP_NAME_DATE = new QName( NSURI_BLACKBERRY, "datMENT_ME
+ * @throws ResourceException DOCUMENT_ME
+ * @throws ResourceContextException DOCUMENT_ME
+ * @throws ResourceUnknownException DOCUMENT_ME
+ */
+ public Resource getInstance(ResourceContext resourceContext)
+ throws ResourceException,
+ ResourceContextException,
+ ResourceUnknownException
+ {
+ ResourceKey key = resourceContext.getResourceKey();
+ BlackberryResource resource = null;
+ try
+ {
+ resource = (BlackberryResource)find(key);
+ }
+ catch (ResourceException re)
+ {
+ Object id = key.getValue();
+ /**
+ * Determine if the passed-in key is, in fact, something we expect.
+ */
+ if (id.equals("bb1") || id.equals("bb2"))
+ {
+ try
+ {
+ resource = (BlackberryResource)createInstance(key);
+ EndpointReference epr = getEndpointReference(resourceContext.getBaseURL( ) + "/" + getServiceName().getLocalPart() , key, SPEC_NAMESPACE_SET.getAddressingNamespace());
+ resource.setEndpointReference(epr);
+ }
+ catch (Exception e)
+ {
+ throw new ResourceException(e);
+ }
+ add(key, resource);
+ }
+ else
+ {
+ throw new ResourceUnknownException(id,
+ resourceContext.getServiceName());
+ }
+ }
+ return resource;
+ }
+
+ public QName getServiceName()
+ {
+ return SERVICE_NAME;
+ }
+
+ public QName getPortType()
+ {
+ return PORT_TYPE;
+ }
+
+ public String getServicePortName()
+ {
+ return PORT_NAME;
+ }
+
+ public QName getResourceKeyNameQName()
+ {
+ return RESOURCE_KEY_NAME;
+ }
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryPropertyQNames.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryPropertyQNames.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryPropertyQNames.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryPropertyQNames.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,38 @@
+package org.apache.ws.resource.example.blackberry;
+
+import javax.xml.namespace.QName;
+
+/**
+ * QNames of the resource properties defined by Blackberry WSDL.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public interface BlackberryPropertyQNames
+{
+
+ QName MANAGEABILIe", NSPREFIX_BLACKBERRY );
+ private static final QName PROP_NAME_TIME = new QName( NSURI_BLACKBERRY, "time", NSPREFIX_BLACKBERRY );
+
+ private ResourceStub m_resource;
+
+ protected void setUp() throws Exception
+ {
+ super.setUp();
+ EndpointReferenceDocument blackberryEprDoc = getEndpointReference( new URL( BLACKBERRY_EPR ) );
+ if ( DEBUG ) { System.out.println( "*** Using Blackberry EPR:\n" + blackberryEprDoc ); }
+ m_resource = new ResourceStub( new XmlBeansEndpointReference(blackberryEprDoc.getEndpointReference()) );
+ }
+
+ public void testMuwsIdentityCharacteristics() throws FaultException
+ {
+ performMuwsIdentityCharacteristicsAct( m_resource );
+ }
+
+ public void testBlackberryMetrics() throws FaultException
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty( ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, MTYCAPABILITY =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part1.xsd", "ManageabilityCapability", "muws-xs1");
+ QName TIME =
+ new QName("http://pda.rim", "time", "bbry");
+ QName TOPICEXPRESSIONDIALECTS =
+ new QName("http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd", "TopicExpressionDialects", "wsnt");
+ QName TOTALCODEMODULESIZE =
+ new QName("http://pda.rim", "TotalCodeModuleSize", "bbry");
+ QName ALLOCATEDSTORAGE =
+ new QName("http://pda.rim", "AllocatedStorage", "bbry");
+ QName RESOURCEID =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part1.xsd", "ResourceId", "muws-xs1");
+ QName FIXEDTOPICSET =
+ new QName("http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd", "FixedTopicSet", "wsnt");
+ QName OPERATIONALSTATUS =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wetricsCapability.URI );
+ assertContainsURI( capabilityElems, CAPABILITY_URI_BLACKBERRY_METRICS );
+
+ XmlObject currentTimePropElem = getSingleProperty( m_resource, MetricsCapability.PROP_NAME_CURRENT_TIME );
+ assertTrue( currentTimePropElem instanceof XmlDateTime );
+ XmlObject allocatedStoragePropElem = getSingleProperty( m_resource, BlackberryPropertyQNames.ALLOCATEDSTORAGE );
+ // TODO: check type & metric attribs
+ XmlObject freeStoragePropElem = getSingleProperty( m_resource, BlackberryPropertyQNames.FREESTORAGE );
+ // TODO: check type & metric attribs
+ XmlObject totalCodeModuleSizePropElem = getSingleProperty( m_resource, BlackberryPropertyQNames.TOTALCODEMODULESIZE );
+ // TODO: check type & metric attribs
+ }
+
+ public void testBlackberryConfiguration() throws FaultException
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty( ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITYsdm-muws-part2.xsd", "OperationalStatus", "muws-xs2");
+ QName CURRENTTIME =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part2.xsd", "CurrentTime", "muws-xs2");
+ QName FREESTORAGE =
+ new QName("http://pda.rim", "FreeStorage", "bbry");
+ QName DATE =
+ new QName("http://pda.rim", "date", "bbry");
+ QName TOPIC =
+ new QName("http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd", "Topic", "wsnt");
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.j_CAPABILITY );
+ assertContainsURI( capabilityElems, ConfigurationCapability.URI );
+ assertContainsURI( capabilityElems, CAPABILITY_URI_BLACKBERRY_CONFIGURATION );
+
+ // set date prop
+ DateDocument dateDoc = DateDocument.Factory.newInstance();
+ DateDocument.Date newDate = dateDoc.addNewDate();
+ newDate.setDay( 24 );
+ newDate.setMonth( 8 );
+ newDate.setYear( 1975 );
+ setSingleProperty( m_resource, dateDoc );
+
+ // set time prop
+ TimeDocument timeDoc = TimeDocument.Factory.newInstance();
+ TimeDocument.Time newTime = timeDoc.addNewTime();
+ newTime.setHour( 6 );
+ newTime.setMinute( 30 );
+ setSingleProperty( m_resource, timeDoc );
+
+ // get date prop and validate value is as we set it
+ XmlObject datePropElem = getSingleProperty( m_resource, PROP_NAME_DATE );
+ assertTrue( datePropElem instanceof DateDocument.Date );
+ DateDocument.Date date = (Daava (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryResource.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,209 @@
+package org.apache.ws.resource.example.blackberry;
+
+import org.apache.ws.muws.v1_0.MuwsConstants;
+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;
+import org.apache.ws.muws.v1_0.capability.OperationalStatusCapability;
+import org.apache.ws.muws.v1_0.topics.ManagementEventTopic;
+import org.apache.ws.muws.v1_0.topics.impl.XmlBeansManagementEventTopicImpl;
+import org.apache.ws.notification.topics.TopicSpace;
+import org.apache.ws.notification.topics.impl.TopicSpaceImpl;
+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.x200teDocument.Date)datePropElem;
+ assertEquals( newDate.getDay(), date.getDay() );
+ assertEquals( newDate.getMonth(), date.getMonth() );
+ assertEquals( newDate.getYear(), date.getYear() );
+
+ // get time prop and validate value is as we set it
+ XmlObject timePropElem = getSingleProperty( m_resource, PROP_NAME_TIME );
+ assertTrue( timePropElem instanceof TimeDocument.Time );
+ TimeDocument.Time time = (TimeDocument.Time)timePropElem;
+ assertEquals( newTime.getHour(), time.getHour() );
+ assertEquals( newTime.getMinute(), time.getMinute() );
+ }
+
+ public void testMuwsStatus() throws FaultException
+ {
+ performMuwsStatusAct( m_resource );
+ }
+
+ public void testMuwsMetricChange() throws Exception
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty( ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, Metrics4.x12.muws.wsdmMuwsPart2.CurrentTimeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.OperationalStatusDocument;
+import rim.pda.AllocatedStorageDocument;
+import rim.pda.DateDocument;
+import rim.pda.FreeStorageDocument;
+import rim.pda.TimeDocument;
+import rim.pda.TotalCodeModuleSizeDocument;
+
+import java.util.Calendar;
+
+/**
+ * A Blackberry WS-Resource.
+ * <p/>
+ * NOTE: This class is generated but IS meant to be modified.
+ */
+public class BlackberryResource extends AbstractBlackberryResource
+
+{
+ /**
+ * A NamespaceVerionHolder which maintains the QNames of Spec Wsdls
+ */
+ public static final org.apache.ws.notification.base.v2004_06.impl.WsnNamespaceVersionHolderImpl SPEC_NAMESPACE_SET = new org.apache.ws.notification.base.v2004_06.impl.WsnNamespaceVersionHolderImpl();
+
+ /**
+ * Initializes this resource's state (properties, etc.).
+ */
+ public void init()
+ {
+ super.init();
+
+ /**
+ *Capability.URI );
+
+ m_resource.subscribe( s_consumerURL, new QName( MuwsConstants.NSURI_MUWS_PART2_TOPICS, MetricsCapability.TOPIC_NAME, MuwsConstants.NSPREFIX_MUWS_PART2_TOPICS ) );
+
+ PortListen notifListener = new PortListen( NOTIF_LISTENER_PORT, NOTIF_LISTENER_TIMEOUT );
+
+ TotalCodeModuleSizeDocument totalCodeModuleSizeDocument = TotalCodeModuleSizeDocument.Factory.newInstance();
+ totalCodeModuleSizeDocument.setTotalCodeModuleSize( 1111 );
+ setSingleProperty( m_resource, totalCodeModuleSizeDocument );
+
+ ManagementEventType mgmtEvent = waitForManagementEvent( notifListener );
+
+ XmlObject propChangedEvent = XmlBeanUtils.getChildElements(mgmtEvent, new QName(ResourcePropertiesConstants.NSURI_WSRP_SCHEMA, "ResourcePropertyValueChangeNotification"))[0];
+ assertNotNull("ManagementEvent does not contain a ResourcePropertyValueChangeNotification", propChangedEvent);
+ }
+
+ public void testBlackberryCodeModuleSizeChangeEvent The ResourcePropertySet which contains all the defined ResourceProperties
+ */
+ org.apache.ws.resource.properties.ResourcePropertySet resourcePropertySet = getResourcePropertySet();
+ org.apache.ws.resource.properties.ResourceProperty resourceProperty = null;
+
+ try
+ {
+ /** Capabilities **/
+ //Management Characteristics
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.MANAGEABILITYCAPABILITY);
+
+ //Identity Capability
+ ManageabilityCapabilityDocument manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability(IdentityCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+ //MUWS2 Metrics Capability
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabil() throws Exception
+ {
+ XmlObject[] capabilityElems = m_resource.getResourceProperty( ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityElems, MetricsCapability.URI );
+
+ m_resource.subscribe( s_consumerURL, new QName( NSURI_BLACKBERRY, "CodeModuleSize", NSPREFIX_BLACKBERRY ) );
+
+ PortListen notifListener = new PortListen( NOTIF_LISTENER_PORT, NOTIF_LISTENER_TIMEOUT );
+
+ TotalCodeModuleSizeDocument totalCodeModuleSizeDocument = TotalCodeModuleSizeDocument.Factory.newInstance();
+ totalCodeModuleSizeDocument.setTotalCodeModuleSize( 9999 );
+ setSingleProperty( m_resource, totalCodeModuleSizeDocument );
+
+ ManagementEventType mgmtEvent = waitForManagementEvent( notifListener );
+
+ XmlObject propChangedEvent = XmlBeanUtils.getChildElements(mgmtEvent, new QName(ResourcePropertiesConstants.NSURI_WSRP_SCHEMA, "ResourcePropertyValueChangeNotification"))[0];
+ assityDocument.setManageabilityCapability(MetricsCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+ //Blackberry Metrics Capability
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability("http://pda.rim/BlackberryMetrics");
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+ //Configuration
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability(ConfigurationCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+ //Blackberry Configuration Capability
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability("http://pda.rim/BlackberryConfiguration");
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+ //Status Capability
+ manageabilityCapabilityDocument = ManageabilityCapabilityDocument.Factory.newInstance();
+ manageabilityCapabilityDocument.setManageabilityCapability(OperationalStatusCapability.URI);
+ resourceProperty.add(manageabilityCapabilityDocument);
+
+
+ /** Topics **/
+ //MUWS TopicSpace
+ TopicSpace muwsTopicSpace = new TopicSpaceImpl(MuwsConstants.NSURI_MUWS_PART2_TOPICS);
+ getTopicSpaceSet().addTopicSpace(muwsTopicSpace);
+
+ ManagementEventTopic operationalStatusCapability = new XmlBeansManagementEventTopicImpl("OperationalStatusCapability");
+ muwsTopicSpace.addTopic(operationalStatusCapability);
+ ManagementEventTopic metricsCapability = new XmlBeansManagementEventTopicImpl("MetricsCapability");
+ muwsTopicSpace.addTopic(metricsCapability);
+ ManagementEventTopic codeModuleSize = new XmlBeansManagementEventTopicImpl("CodeModuleSize");
+
+ //Blackberry TopicSpace
+ TopicSpace bbryTopicSpace = new TopicSpaceImpl(BlackberryPropertyQNames.ALLOCATEDSTORAGE.getNamespaceURI());
+ getTopicSpaceSet().addTopicSpace(bbryTopicSpace);
+ bbryTopicSpace.addTopic(codeModuleSize);
+
+ /** Properties **/
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.RESOURCEID);
+ ResourceIdDocument resourceIdDocument = ResourceIdDocument.Factory.newInstance();
+ resourceIdDocument.setResourceId("urn:" + (String) getID());
+ resourceProperty.add(resourceIdDocument);
+
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.ALLOCATEDSTORAGE);
+ AllocatedStorageDocument allocatedStorageDocument = AllocatedStorageDocument.Factory.newInstance();
+ allocatedStorageDocument.setAllocatedStorage(1024);
ertNotNull("ManagementEvent does not contain a ResourcePropertyValueChangeNotification", propChangedEvent);
+ }
+
+ public void testMuwsStatusChangeEvent() throws Exception
+ {
+ XmlObject[] capabilityPropElems = m_resource.getResourceProperty(
+ ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
+ assertContainsURI( capabilityPropElems, OperationalStatusCapability.URI );
+
+ // init status to Available
+ OperationalStatusDocument operationalStatusDoc = OperationalStatusDocument.Factory.newInstance();
+ operationalStatusDoc.setOperationalStatus( OperationalStatusDocument.OperationalStatus.AVAILABLE );
+ setSingleProperty( m_resource, operationalStatusDoc );
+
+ m_resource.subscribe( s_consumerURL, new QName( MuwsConstants.NSURI_MUWS_PART2_TOPICS, OperationalStatusCapability.TOPIC_NAME, MuwsConstants.NSPREFIX_MUWS_PART2_TOPICS ) );
+ PortListen notifListener = new PortListen( NOTIF_LISTENER_
+ resourceProperty.add(allocatedStorageDocument);
+ resourceProperty.addChangeListener(metricsCapability);
+
+ //Calendar for use in a few properties
+ Calendar calendarInstance = Calendar.getInstance();
+
+
+ //current time is done like in WSRF
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.CURRENTTIME);
+ CurrentTimeDocument currentTimeDocument = CurrentTimeDocument.Factory.newInstance();
+ currentTimeDocument.setCurrentTime(calendarInstance);
+ resourceProperty.add(currentTimeDocument);
+ resourceProperty.setCallback(new org.apache.ws.resource.lifetime.callback.CurrentTimeCallback());
+ resourceProperty.addChangeListener(metricsCapability);
+
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.DATE);
+ DateDocument dateDocument = DateDocument.Factory.newInstance();
+ DateDocument.Date date = dateDPORT, NOTIF_LISTENER_TIMEOUT );
+
+ // change status to Unavailable
+ operationalStatusDoc.setOperationalStatus( OperationalStatusDocument.OperationalStatus.UNAVAILABLE );
+ setSingleProperty( m_resource, operationalStatusDoc );
+
+ // make sure we receive a propChanged mgmtEvent
+ ManagementEventType mgmtEvent = waitForManagementEvent( notifListener );
+ XmlObject[] propChangedEvents = XmlBeanUtils.getChildElements(mgmtEvent, new QName(ResourcePropertiesConstants.NSURI_WSRP_SCHEMA, "ResourcePropertyValueChangeNotification"));
+ assertEquals( "ManagementEvent does not contain a single ResourcePropertyValueChangeNotification", 1, propChangedEvents.length );
+ assertTrue( propChangedEvents[0] instanceof ResourcePropertyValueChangeNotificationType );
+ ResourcePropertyValueChangeNotificationType propChangedEvent = (ResourcePropertyValueChangeNotificationType)propChangedEvents[0];
+ assertFalse( propChangedEvent.getNewValue().toStriocument.addNewDate();
+ date.setDay(calendarInstance.get(Calendar.DAY_OF_MONTH));
+ date.setMonth(calendarInstance.get(Calendar.MONTH));
+ date.setYear(calendarInstance.get(Calendar.YEAR));
+ dateDocument.setDate(date);
+ resourceProperty.add(dateDocument);
+
+
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.FREESTORAGE);
+ FreeStorageDocument freeStorageDocument = FreeStorageDocument.Factory.newInstance();
+ freeStorageDocument.setFreeStorage(384);
+ resourceProperty.add(freeStorageDocument);
+ resourceProperty.addChangeListener(metricsCapability);
+
+
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.OPERATIONALSTATUS);
+ OperationalStatusDocument operationalStatusDocument = OperationalStatusDocument.Factory.newInstance();
+ operationalStatusDocument.setOperationalStatus(OperationalStatusDocument.OperationalSng().equals( propChangedEvent.getOldValue().toString() ) );
+ }
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: muse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: muse-dev-help@ws.apache.org
tatus.AVAILABLE);
+ resourceProperty.add(operationalStatusDocument);
+ resourceProperty.addChangeListener(operationalStatusCapability);
+
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.TIME);
+ TimeDocument timeDocument = TimeDocument.Factory.newInstance();
+ TimeDocument.Time time = timeDocument.addNewTime();
+ time.setHour(calendarInstance.get(Calendar.HOUR_OF_DAY));//24 hr clock..no indication in spec
+ time.setMinute(calendarInstance.get(Calendar.MINUTE));
+ resourceProperty.add(timeDocument);
+
+ resourceProperty = resourcePropertySet.get(BlackberryPropertyQNames.TOTALCODEMODULESIZE);
+ TotalCodeModuleSizeDocument totalCodeModuleSizeDocument = TotalCodeModuleSizeDocument.Factory.newInstance();
+ totalCodeModuleSizeDocument.setTotalCodeModuleSize(256);
+ resourceProperty.add(totalCodeModuleSizeDocument);
+ resourceProperty.addChangeListener(codeModuleSize);
+ resourceProperty.addChangeListener(metricsCapability);
+ }
+ catch (Exception e)
+ {
+ throw new javax.xml.rpc.JAXRPCException("There was a problem in initializing your resource properties. Please check your init() method. Cause: " + e.getLocalizedMessage());
+ }
+ // Resource Property {http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd}FixedTopicSet is implemented by the framework.
+ // Resource Property {http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd}Topic is implemented by the framework.
+ // Resource Property {http://docs.oasis-open.org/wsn/2004/06/wsn-WS-BaseNotification-1.2-draft-01.xsd}TopicExpressionDialects is implemented by the framework.
+
+
+
+ /**
+ * 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.
+ */
+ try
+ {
+ org.apache.ws.notification.topics.util.TopicUtils.addResourcePropertyValueChangeTopics(getResourcePropertySet(), getTopicSpaceSet());
+ }
+ catch (Exception e)
+ {
+ throw new javax.xml.rpc.JAXRPCException("Unable to init the ResourceProperty Changed topics. Cause: " + e.getLocalizedMessage(), e);
+ }
+
+ /**
+ * Initializes the Topic, TopicExpressionDialects and FixedTopicSet resource properties
+ *
+ * </br>
+ * <strong>NOTE this MUST be called last in the Resource.init() method to ensure all topics get registered</strong>
+ * </br>
+ * FixedTopicSet will be set based on the value returned from the {@see TopicSpaceSet#isFixed()} method.
+ * </br>
+ * Topic will have all root topics in the TopicSpaceSet, set to Simple dialect AND all child topics set ot
+ * Concrete dialect.
+ * </br>
+ *
+ * TopicExpressionDialects will be set to the engine's known Topic Dialects acquired from the TopicExpressionEngine
+ *
+ * @param topicSpaceSet
+ * @param propSet
+ */
+ org.apache.ws.notification.topics.util.TopicUtils.initNotificationProducerProperties(getTopicSpaceSet(), getResourcePropertySet());
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryService.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryService.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryService.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/BlackberryService.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,43 @@
+package org.apache.ws.resource.example.blackberry;
+
+import org.apache.ws.resource.ResourceContext;
+
+/**
+ * This class should be generated ONCE (and not overwritten) to maintain user-added code.
+ * If there is a change to the WSDL, then the generated implemented interfaces
+ * (representing the "base" portTypes) will change, thus showing a compile error to the
+ * user.
+ * <p/>
+ * NOTE: This class is generated. However, it will not be overwritten by subsequent
+ * calls to the code generator.
+ */
+public class BlackberryService
+ extends AbstractBlackberryService
+ implements BlackberryCustomOperationsPortType
+{
+
+ private ResourceContext m_resourceContext;
+
+ /**
+ * Creates a new {@link BlackberryService } object.
+ *
+ * @param resourceContext DOCUMENT_ME
+ */
+ public BlackberryService(ResourceContext resourceContext)
+ {
+ m_resourceContext = resourceContext;
+ init();
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public ResourceContext getResourceContext()
+ {
+ return m_resourceContext;
+ }
+
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_deploy.wsdd
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_deploy.wsdd?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_deploy.wsdd (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_deploy.wsdd Thu Jul 21 09:37:14 2005
@@ -0,0 +1,26 @@
+<?xml version="1.0"?>
+
+<deployment xmlns="http://xml.apache.org/axis/wsdd/"
+ xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
+
+ <service name="blackberry" provider="java:WSRF" style="document" use="literal">
+
+ <wsdlFile>/wsdl/blackberry.wsdl</wsdlFile>
+
+ <requestFlow>
+ <handler type="java:org.apache.axis.handlers.JAXRPCHandler">
+ <parameter name="className" value="org.apache.axis.message.addressing.handler.AxisServerSideAddressingHandler" />
+ <parameter name="referencePropertyNames" value="*" />
+ </handler>
+ </requestFlow>
+
+ <responseFlow>
+ <handler type="java:org.apache.axis.handlers.JAXRPCHandler">
+ <parameter name="className" value="org.apache.axis.message.addressing.handler.AxisServerSideAddressingHandler" />
+ <parameter name="referencePropertyNames" value="*" />
+ </handler>
+ </responseFlow>
+
+ </service>
+
+</deployment>
Added: webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_jndi-config.xml
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_jndi-config.xml?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_jndi-config.xml (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/apache/ws/resource/example/blackberry/Blackberry_jndi-config.xml Thu Jul 21 09:37:14 2005
@@ -0,0 +1,30 @@
+<?xml version="1.0"?>
+
+<jndiConfig xmlns="http://www.apache.org/wsfx/wsrf/jndi/config">
+
+ <service name="blackberry">
+ <resource name="home" type="org.apache.ws.resource.example.blackberry.BlackberryHome">
+ <resourceParams>
+ <parameter>
+ <name>serviceClassName</name>
+ <value>org.apache.ws.resource.example.blackberry.BlackberryService</value>
+ </parameter>
+ <parameter>
+ <name>resourceClassName</name>
+ <value>org.apache.ws.resource.example.blackberry.BlackberryResource</value>
+ </parameter>
+ <parameter>
+ <name>wsdlTargetNamespace</name>
+ <value>http://ws.apache.org/resource/example/blackberry</value>
+ </parameter>
+
+ <parameter>
+ <name>resourceKeyName</name>
+ <value>{http://ws.apache.org/resource/example/blackberry}ResourceID</value>
+ </parameter>
+ </resourceParams>
+ </resource>
+ </service>
+
+</jndiConfig>
+
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapHome.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapHome.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapHome.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapHome.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,51 @@
+package org.everest;
+
+import org.apache.ws.resource.impl.AbstractResourceHome;
+import org.apache.commons.collections.map.ReferenceMap;
+
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Collections;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+/**
+ * This class should not be modified.
+ * <p/>
+ * The class acts as an extension of the AbstractResourceHome which
+ * maintains a reference to the STATIC map needed for accessing resources via JNDI.
+ * <p/>
+ * This ensures the resources will be accessible if serialized via JNDI in certain platforms.
+ */
+abstract class AbstractWeatherStationSoapHome extends AbstractResourceHome
+{
+ /**
+ * The static reference which is maintained and used by the AbstractResourceHome.
+ * <p/>
+ * Do not modify.
+ */
+ private static Map m_resource;
+
+ /**
+ * Do not modify this method.
+ */
+ protected final Map initResourceMap()
+ throws NamingException
+ {
+ Context initialContext = new InitialContext();
+ if (m_resourceIsPersistent)
+ {
+ m_resources = new ReferenceMap(ReferenceMap.HARD, ReferenceMap.SOFT, true);
+ initCachePolicy(initialContext);
+ }
+ else
+ {
+ m_resources = new HashMap();
+ }
+
+ m_resources = Collections.synchronizedMap(m_resources);
+ return m_resources;
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapResource.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapResource.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapResource.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapResource.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,111 @@
+package org.everest;
+
+import org.apache.ws.addressing.EndpointReference;
+
+/**
+ * An abstract WeatherStationSoap WS-Resource.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public abstract class AbstractWeatherStationSoapResource implements org.apache.ws.resource.Resource
+{
+
+ /**
+ * The resource ID of the instance.
+ */
+ protected String m_id;
+
+ /**
+ * The EndpointReference for this resource *
+ */
+ protected EndpointReference m_endpointReference;
+
+ /**
+ * A list of termination listeners to be notified when the resource is terminated.
+ */
+ private java.util.List m_terminationListeners = new java.util.ArrayList();
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param id DOCUMENT_ME
+ */
+ public void setID(Object id)
+ {
+ if (m_id != null)
+ {
+ throw new IllegalStateException("This resource's ID has already been set.");
+ }
+
+ try
+ {
+ m_id = (String) id;
+ }
+ catch (ClassCastException cce)
+ {
+ throw new IllegalArgumentException("Specified ID is not a String.");
+ }
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param listener DOCUMENT_ME
+ */
+ public void addTerminationListener(org.apache.ws.resource.lifetime.ResourceTerminationListener listener)
+ {
+ m_terminationListeners.add(listener);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public Object getID()
+ {
+ return m_id;
+ }
+
+ public void destroy()
+ {
+ org.apache.ws.resource.lifetime.ResourceTerminationEvent rte = new org.apache.ws.resource.lifetime.impl.ResourceTerminationEventImpl(getID(), "Resource Destroyed");
+ for (int i = 0; i < m_terminationListeners.size(); i++)
+ {
+ org.apache.ws.resource.lifetime.ResourceTerminationListener resourceTerminationEventListener = (org.apache.ws.resource.lifetime.ResourceTerminationListener) m_terminationListeners.get(i);
+ resourceTerminationEventListener.terminationOccurred(rte);
+ }
+ return;
+ }
+
+ public void init()
+ {
+
+
+ }
+
+ /**
+ * Returns the EndpointReference associated with this Resource.
+ *
+ * @return The Resource's EndpointReference or null if the EndpointReference has not been set.
+ * <p/>
+ * Note: It is the responsibility of the Resource creator to set the EndpointReference (i.e. ResourceHome impl)
+ */
+ public EndpointReference getEndpointReference()
+ {
+ return m_endpointReference;
+ }
+
+ /**
+ * Sets the EndpointReference associated with this Resource.
+ *
+ * @param epr The Resource's EndpointReference.
+ * <p/>
+ * Note: It is the responsibility of the Resource creator to set the EndpointReference (i.e. ResourceHome impl)
+ */
+ public void setEndpointReference(EndpointReference epr)
+ {
+ m_endpointReference = epr;
+ }
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapService.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapService.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapService.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/AbstractWeatherStationSoapService.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,89 @@
+package org.everest;
+
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.handler.ServiceSoapMethodNameMap;
+import org.apache.ws.resource.handler.SoapMethodNameMap;
+
+import javax.xml.namespace.QName;
+
+/**
+ * This class should be generated on every "generation" against the WSDL.
+ * This will ensure it is always up-to-date with the WSDL.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public abstract class AbstractWeatherStationSoapService
+ implements org.apache.ws.resource.handler.WsrfService, org.apache.ws.mows.v1_0.capability.ManageabilityReferencesCapability
+{
+
+ public static final String TARGET_NSURI = "http://everest.org/";
+ public static final String TARGET_NSPREFIX = "everest.org";
+
+ /**
+ * DOCUMENT_ME
+ */
+ private ServiceSoapMethodNameMap m_methodNameMap;
+
+ /**
+ * DOCUMENT_ME
+ */
+ private boolean m_isInitialized;
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestQname DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public String getMethodName(QName requestQname)
+ {
+ if (!m_isInitialized)
+ {
+ init();
+ }
+
+ return m_methodNameMap.getMethodName(requestQname);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public abstract ResourceContext getResourceContext();
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public final SoapMethodNameMap getMethodNameMap()
+ {
+ return m_methodNameMap;
+ }
+
+ /**
+ * DOCUMENT_ME
+ */
+ public void init()
+ {
+ m_methodNameMap = new ServiceSoapMethodNameMap(getResourceContext());
+ m_methodNameMap.addMapping(javax.xml.namespace.QName.valueOf("{http://everest.org/}GetCurrentTemperature"), "GetCurrentTemperature");
+ m_isInitialized = true;
+ }
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ protected final boolean isInitialized()
+ {
+ return m_isInitialized;
+ }
+
+
+ public abstract org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.GetManageabilityReferencesResponseDocument getManageabilityReferences(org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.GetManageabilityReferencesDocument request);
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapCustomOperationsPortType.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapCustomOperationsPortType.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapCustomOperationsPortType.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapCustomOperationsPortType.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,13 @@
+package org.everest;
+
+/**
+ * Custom operations portType.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public interface WeatherStationSoapCustomOperationsPortType
+{
+
+ public org.everest.GetCurrentTemperatureResponseDocument GetCurrentTemperature(org.everest.GetCurrentTemperatureDocument requestDoc);
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapHome.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapHome.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapHome.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapHome.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,98 @@
+package org.everest;
+
+import org.apache.ws.resource.Resource;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.ResourceContextException;
+import org.apache.ws.resource.ResourceException;
+import org.apache.ws.resource.ResourceKey;
+import org.apache.ws.resource.ResourceUnknownException;
+import org.apache.ws.resource.impl.AbstractResourceHome;
+
+import javax.xml.namespace.QName;
+import java.io.Serializable;
+
+/**
+ * Home for WeatherStationSoap WS-Resources.
+ */
+public class WeatherStationSoapHome
+ extends AbstractWeatherStationSoapHome
+ implements Serializable
+{
+
+ /**
+ * The service endpoint name as registered with the SOAP Platform. This is useful for building EPR's. *
+ */
+ public static final QName SERVICE_NAME = javax.xml.namespace.QName.valueOf("{http://everest.org/}WeatherStationSoap");
+
+ /**
+ * The management PortType associated with this resource. This is useful for building EPR's.*
+ */
+ public static final QName PORT_TYPE = javax.xml.namespace.QName.valueOf("{http://everest.org/}WeatherStationSoap");
+
+ /**
+ * The WSDL Port name associated with the resource. This is useful for building EPR's. *
+ */
+ public static final String PORT_NAME = "WeatherStationSoap";
+
+ /**
+ * The name of the resource key for this resource. *
+ */
+ public static final QName RESOURCE_KEY_NAME = javax.xml.namespace.QName.valueOf("{http://everest.org/}ResourceID");
+
+ /**
+ * A NamespaceVerionHolder which maintains the QNames of Spec Wsdls
+ */
+ public static final org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl SPEC_NAMESPACE_SET = new org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl();
+ /**
+ * A constant for the JNDI Lookup name for this home. *
+ */
+ public static final String HOME_LOCATION =
+ org.apache.ws.resource.JndiConstants.CONTEXT_NAME_SERVICES + "/" + SERVICE_NAME.getLocalPart() + "/" + org.apache.ws.resource.JndiConstants.ATOMIC_NAME_HOME;
+
+ /**
+ * TODO
+ *
+ * @param resourceContext DOCUMENT_ME
+ * @return DOCUMENT_ME
+ * @throws ResourceException DOCUMENT_ME
+ * @throws ResourceContextException DOCUMENT_ME
+ * @throws ResourceUnknownException DOCUMENT_ME
+ */
+ public Resource getInstance(ResourceContext resourceContext)
+ throws ResourceException,
+ ResourceContextException,
+ ResourceUnknownException
+ {
+ ResourceKey key = resourceContext.getResourceKey();
+ Resource resource = null;
+ try
+ {
+ resource = find(key);
+ }
+ catch (ResourceException re)
+ {
+ //todo add any checking for key validity
+ }
+ return resource;
+ }
+
+ public QName getServiceName()
+ {
+ return SERVICE_NAME;
+ }
+
+ public QName getPortType()
+ {
+ return PORT_TYPE;
+ }
+
+ public String getServicePortName()
+ {
+ return PORT_NAME;
+ }
+
+ public QName getResourceKeyNameQName()
+ {
+ return RESOURCE_KEY_NAME;
+ }
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapResource.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapResource.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapResource.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapResource.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,24 @@
+package org.everest;
+
+/**
+ * A WeatherStationSoap WS-Resource.
+ * <p/>
+ * NOTE: This class is generated but IS meant to be modified.
+ */
+public class WeatherStationSoapResource extends AbstractWeatherStationSoapResource
+
+{
+
+
+ /**
+ * Initializes this resource's state (properties, etc.).
+ */
+ public void init()
+ {
+ super.init();
+
+
+ // TODO: init all custom properties - this includes setting values, registering callbacks, and adding prop value changed topics
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapService.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapService.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapService.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoapService.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,160 @@
+package org.everest;
+
+import org.apache.ws.XmlObjectWrapper;
+import org.apache.ws.mows.v1_0.MowsConstants;
+import org.apache.ws.muws.impl.CategoryImpl;
+import org.apache.ws.muws.v1_0.MuwsConstants;
+import org.apache.ws.muws.v1_0.events.Situation;
+import org.apache.ws.muws.v1_0.events.impl.SituationImpl;
+import org.apache.ws.muws.v1_0.events.impl.XmlBeansManagementEvent;
+import org.apache.ws.notification.topics.Topic;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.example.InteropConstants;
+import org.apache.ws.resource.impl.SimpleTypeResourceKey;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.xmlbeans.XmlObject;
+import org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationHome;
+import org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationPropertyQNames;
+import org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationResource;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.AnyXmlContentsType;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.GetManageabilityReferencesDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.GetManageabilityReferencesResponseDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.MessageContentType;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.MessageInformationType;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.RequestProcessingNotificationDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.RequestProcessingStateInformationType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.StateTransitionType;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.StateType;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.AttributedURI;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.EndpointReferenceType;
+import org.xmlsoap.schemas.ws.x2004.x08.addressing.ReferencePropertiesType;
+
+import javax.naming.InitialContext;
+import javax.xml.namespace.QName;
+import java.util.Calendar;
+
+/**
+ * This class should be generated ONCE (and not overwritten) to maintain user-added code. If there is a change to the
+ * WSDL, then the generated implemented interfaces (representing the "base" portTypes) will change, thus showing a
+ * compile error to the user.
+ * <p/>
+ * NOTE: This class is generated. However, it will not be overwritten by subsequent calls to the code generator.
+ */
+public class WeatherStationSoapService
+ extends AbstractWeatherStationSoapService
+ implements WeatherStationSoapCustomOperationsPortType
+{
+
+ private ResourceContext m_resourceContext;
+
+ /**
+ * Creates a new {@link WeatherStationSoapService } object.
+ *
+ * @param resourceContext DOCUMENT_ME
+ */
+ public WeatherStationSoapService(ResourceContext resourceContext)
+ {
+ m_resourceContext = resourceContext;
+ init();
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public ResourceContext getResourceContext()
+ {
+ return m_resourceContext;
+ }
+
+ public GetManageabilityReferencesResponseDocument getManageabilityReferences(GetManageabilityReferencesDocument request)
+ {
+ GetManageabilityReferencesResponseDocument getManageabilityReferencesResponseDocument = GetManageabilityReferencesResponseDocument.Factory.newInstance();
+ GetManageabilityReferencesResponseDocument.GetManageabilityReferencesResponse getManageabilityReferencesResponse = getManageabilityReferencesResponseDocument.addNewGetManageabilityReferencesResponse();
+ QName resourceKeyName = QName.valueOf("{" + WeatherstationPropertyQNames.FCCID.getNamespaceURI() + "}ResourceID");
+ EndpointReferenceType endpointReferenceType = getManageabilityReferencesResponse.addNewManageabilityEndpointReference();
+ AttributedURI attributedURI = endpointReferenceType.addNewAddress();
+ attributedURI.setStringValue(InteropConstants.SERVICES_URL + "/" + InteropConstants.WEATHERSTATION_SERVICE_NAME);
+ ReferencePropertiesType referencePropertiesType = endpointReferenceType.addNewReferenceProperties();
+ XmlObject key1 = XmlBeanUtils.addChildElement(referencePropertiesType, resourceKeyName);
+ XmlBeanUtils.setValue(key1, InteropConstants.WEATHERSTATION_KEY1);
+
+ EndpointReferenceType endpointReferenceType2 = getManageabilityReferencesResponse.addNewManageabilityEndpointReference();
+ attributedURI = endpointReferenceType2.addNewAddress();
+ attributedURI.setStringValue(InteropConstants.SERVICES_URL + "/" + InteropConstants.WEATHERSTATION_SERVICE_NAME);
+ referencePropertiesType = endpointReferenceType2.addNewReferenceProperties();
+ key1 = XmlBeanUtils.addChildElement(referencePropertiesType, resourceKeyName);
+ XmlBeanUtils.setValue(key1, InteropConstants.WEATHERSTATION_KEY2);
+
+ return getManageabilityReferencesResponseDocument;
+ }
+
+ public org.everest.GetCurrentTemperatureResponseDocument GetCurrentTemperature(org.everest.GetCurrentTemperatureDocument getCurrentTemperatureRequestDoc)
+ {
+ GetCurrentTemperatureResponseDocument getCurrentTemperatureResponseDocument = GetCurrentTemperatureResponseDocument.Factory.newInstance();
+ GetCurrentTemperatureResponseDocument.GetCurrentTemperatureResponse getCurrentTemperatureResponse = getCurrentTemperatureResponseDocument.addNewGetCurrentTemperatureResponse();
+ Double aDouble = new Double(101);
+ getCurrentTemperatureResponse.setGetCurrentTemperatureResult(aDouble.doubleValue());
+
+ try
+ {
+ InitialContext initialContext = new InitialContext();
+ WeatherstationHome home = (WeatherstationHome) initialContext.lookup(WeatherstationHome.HOME_LOCATION);
+ SimpleTypeResourceKey simpleTypeResourceKey = new SimpleTypeResourceKey(new QName(WeatherstationPropertyQNames.FCCID.getNamespaceURI(), "ResourceID"),
+ InteropConstants.WEATHERSTATION_KEY1);
+ WeatherstationResource resource = (WeatherstationResource) home.find(simpleTypeResourceKey);
+ Topic topic = resource.getTopicSpaceSet().getTopicSpace(MowsConstants.NSURI_MOWS_TOPICS).getTopic("RequestProcessingObservations");
+ Calendar currentTime = Calendar.getInstance();
+
+ //RequestProcessingNotification
+ RequestProcessingNotificationDocument notifDocument = RequestProcessingNotificationDocument.Factory.newInstance();
+ RequestProcessingNotificationDocument.RequestProcessingNotification notif = notifDocument.addNewRequestProcessingNotification();
+
+ //request message
+ MessageInformationType requestInformationType = notif.addNewRequest();
+ MessageContentType requestMessage = requestInformationType.addNewMessage();
+ AnyXmlContentsType requestAnyXmlContentsType = requestMessage.addNewXml();
+ XmlBeanUtils.addChildElement(requestAnyXmlContentsType, getCurrentTemperatureRequestDoc);
+
+ //reply message
+ MessageInformationType replyInformationType = notif.addNewReply();
+ MessageContentType replyMessage = replyInformationType.addNewMessage();
+ AnyXmlContentsType replyAnyXmlContentsType = replyMessage.addNewXml();
+ XmlBeanUtils.addChildElement(replyAnyXmlContentsType, getCurrentTemperatureResponseDocument);
+
+ //todo flesh out
+ //StateInformation
+ RequestProcessingStateInformationType requestProcessingStateInformationType = notif.addNewStateInformation();
+ StateTransitionType stateTransitionType = requestProcessingStateInformationType.addNewStateTransition();
+
+ XmlObject currentState = XmlObject.Factory.parse("<tns:temp xmlns:tns=\"http://tempcentral.com/temps\">Cool</tns:temp>");
+
+ StateType enteredState = stateTransitionType.addNewEnteredState();
+ XmlBeanUtils.addChildElement(enteredState, currentState);
+
+ StateType prevState = stateTransitionType.addNewPreviousState();
+ XmlBeanUtils.addChildElement(prevState, currentState);
+
+ stateTransitionType.setTransitionIdentifier("urn:NONE");
+ stateTransitionType.setTime(currentTime);
+ notif.setCurrentTime(currentTime);
+
+ Situation situation = new SituationImpl(new CategoryImpl(MuwsConstants.SITUATION_OTHER));
+ XmlBeansManagementEvent xme = new XmlBeansManagementEvent(situation);
+ ManagementEventDocument mgmtEvent = (ManagementEventDocument) ((XmlObjectWrapper) xme).getXmlObject();
+ org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventType managementEvent = mgmtEvent.getManagementEvent();
+ XmlBeanUtils.addChildElement(managementEvent, notifDocument);
+
+ topic.publish(mgmtEvent);
+ }
+ catch (Exception e)
+ {
+ e.printStackTrace();
+ }
+
+ return getCurrentTemperatureResponseDocument;
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_deploy.wsdd
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_deploy.wsdd?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_deploy.wsdd (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_deploy.wsdd Thu Jul 21 09:37:14 2005
@@ -0,0 +1,26 @@
+<?xml version="1.0"?>
+
+<deployment xmlns="http://xml.apache.org/axis/wsdd/"
+ xmlns:java="http://xml.apache.org/axis/wsdd/providers/java">
+
+ <service name="WeatherStationSoap" provider="java:WSRF" style="document" use="literal">
+
+ <wsdlFile>/wsdl/weatherws.wsdl</wsdlFile>
+
+ <requestFlow>
+ <handler type="java:org.apache.axis.handlers.JAXRPCHandler">
+ <parameter name="className" value="org.apache.axis.message.addressing.handler.AxisServerSideAddressingHandler" />
+ <parameter name="referencePropertyNames" value="*" />
+ </handler>
+ </requestFlow>
+
+ <responseFlow>
+ <handler type="java:org.apache.axis.handlers.JAXRPCHandler">
+ <parameter name="className" value="org.apache.axis.message.addressing.handler.AxisServerSideAddressingHandler" />
+ <parameter name="referencePropertyNames" value="*" />
+ </handler>
+ </responseFlow>
+
+ </service>
+
+</deployment>
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_jndi-config.xml
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_jndi-config.xml?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_jndi-config.xml (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everest/WeatherStationSoap_jndi-config.xml Thu Jul 21 09:37:14 2005
@@ -0,0 +1,32 @@
+<?xml version="1.0"?>
+
+<jndiConfig xmlns="http://www.apache.org/wsfx/wsrf/jndi/config">
+
+ <service name="WeatherStationSoap">
+ <resource name="home" type="org.everest.WeatherStationSoapHome">
+ <resourceParams>
+ <parameter>
+ <name>serviceClassName</name>
+ <value>org.everest.WeatherStationSoapService</value>
+ </parameter>
+ <parameter>
+ <name>resourceClassName</name>
+ <value>org.everest.WeatherStationSoapResource</value>
+ </parameter>
+ <parameter>
+ <name>wsdlTargetNamespace</name>
+ <value>http://everest.org/</value>
+ </parameter>
+
+ <parameter>
+ <name>resourceKeyName</name>
+ <value>{http://everest.org/}ResourceID</value>
+ </parameter>
+
+
+ </resourceParams>
+ </resource>
+ </service>
+
+</jndiConfig>
+
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationHome.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationHome.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationHome.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationHome.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,51 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import org.apache.ws.resource.impl.AbstractResourceHome;
+import org.apache.commons.collections.map.ReferenceMap;
+
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Collections;
+import javax.naming.Context;
+import javax.naming.InitialContext;
+import javax.naming.NamingException;
+
+/**
+ * This class should not be modified.
+ * <p/>
+ * The class acts as an extension of the AbstractResourceHome which
+ * maintains a reference to the STATIC map needed for accessing resources via JNDI.
+ * <p/>
+ * This ensures the resources will be accessible if serialized via JNDI in certain platforms.
+ */
+abstract class AbstractWeatherstationHome extends AbstractResourceHome
+{
+ /**
+ * The static reference which is maintained and used by the AbstractResourceHome.
+ * <p/>
+ * Do not modify.
+ */
+ private static Map m_resource;
+
+ /**
+ * Do not modify this method.
+ */
+ protected final Map initResourceMap()
+ throws NamingException
+ {
+ Context initialContext = new InitialContext();
+ if (m_resourceIsPersistent)
+ {
+ m_resources = new ReferenceMap(ReferenceMap.HARD, ReferenceMap.SOFT, true);
+ initCachePolicy(initialContext);
+ }
+ else
+ {
+ m_resources = new HashMap();
+ }
+
+ m_resources = Collections.synchronizedMap(m_resources);
+ return m_resources;
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationResource.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationResource.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationResource.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationResource.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,153 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import org.apache.ws.addressing.EndpointReference;
+
+/**
+ * An abstract Weatherstation WS-Resource.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public abstract class AbstractWeatherstationResource implements org.apache.ws.resource.PropertiesResource, org.apache.ws.notification.base.NotificationProducerResource
+{
+
+ /**
+ * The resource ID of the instance.
+ */
+ protected String m_id;
+
+ /**
+ * The EndpointReference for this resource *
+ */
+ protected EndpointReference m_endpointReference;
+
+ /**
+ * The set of properties associated with this resource.
+ */
+ protected org.apache.ws.resource.properties.ResourcePropertySet m_propSet;
+
+
+ /**
+ * A list of termination listeners to be notified when the resource is terminated.
+ */
+ private java.util.List m_terminationListeners = new java.util.ArrayList();
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param id DOCUMENT_ME
+ */
+ public void setID(Object id)
+ {
+ if (m_id != null)
+ {
+ throw new IllegalStateException("This resource's ID has already been set.");
+ }
+
+ try
+ {
+ m_id = (String) id;
+ }
+ catch (ClassCastException cce)
+ {
+ throw new IllegalArgumentException("Specified ID is not a String.");
+ }
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param listener DOCUMENT_ME
+ */
+ public void addTerminationListener(org.apache.ws.resource.lifetime.ResourceTerminationListener listener)
+ {
+ m_terminationListeners.add(listener);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public Object getID()
+ {
+ return m_id;
+ }
+
+ public void destroy()
+ {
+ org.apache.ws.resource.lifetime.ResourceTerminationEvent rte = new org.apache.ws.resource.lifetime.impl.ResourceTerminationEventImpl(getID(), "Resource Destroyed");
+ for (int i = 0; i < m_terminationListeners.size(); i++)
+ {
+ org.apache.ws.resource.lifetime.ResourceTerminationListener resourceTerminationEventListener = (org.apache.ws.resource.lifetime.ResourceTerminationListener) m_terminationListeners.get(i);
+ resourceTerminationEventListener.terminationOccurred(rte);
+ }
+ return;
+ }
+
+ public void init()
+ {
+
+ org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherStationPropertiesDocument propsDoc = org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherStationPropertiesDocument.Factory.newInstance();
+ m_propSet = new org.apache.ws.resource.properties.impl.XmlBeansResourcePropertySet(propsDoc);
+
+
+ // initialize wsrl:Topic property
+ // TODO
+
+ // initialize wsrl:FixedTopicSet property
+ // TODO
+
+ // initialize wsrl:TopicExpressionDialects property
+ // TODO
+
+
+ }
+
+ /**
+ * @see org.apache.ws.resource.PropertiesResource#setResourcePropertySet(org.apache.ws.resource.properties.ResourcePropertySet)
+ */
+ public void setResourcePropertySet(org.apache.ws.resource.properties.ResourcePropertySet propSet)
+ {
+ m_propSet = propSet;
+ }
+
+ /**
+ * @see org.apache.ws.resource.PropertiesResource#getResourcePropertySet()
+ */
+ public org.apache.ws.resource.properties.ResourcePropertySet getResourcePropertySet()
+ {
+ return m_propSet;
+ }
+
+ org.apache.ws.notification.topics.TopicSpaceSet m_topicSpaceSet = new org.apache.ws.notification.topics.impl.TopicSpaceSetImpl(true);
+
+ public org.apache.ws.notification.topics.TopicSpaceSet getTopicSpaceSet()
+ {
+ return m_topicSpaceSet;
+ }
+
+ /**
+ * Returns the EndpointReference associated with this Resource.
+ *
+ * @return The Resource's EndpointReference or null if the EndpointReference has not been set.
+ * <p/>
+ * Note: It is the responsibility of the Resource creator to set the EndpointReference (i.e. ResourceHome impl)
+ */
+ public EndpointReference getEndpointReference()
+ {
+ return m_endpointReference;
+ }
+
+ /**
+ * Sets the EndpointReference associated with this Resource.
+ *
+ * @param epr The Resource's EndpointReference.
+ * <p/>
+ * Note: It is the responsibility of the Resource creator to set the EndpointReference (i.e. ResourceHome impl)
+ */
+ public void setEndpointReference(EndpointReference epr)
+ {
+ m_endpointReference = epr;
+ }
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationService.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationService.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationService.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/AbstractWeatherstationService.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,137 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import org.apache.ws.muws.v1_0.capability.impl.RelationshipsCapabilityImpl;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.handler.ServiceSoapMethodNameMap;
+import org.apache.ws.resource.handler.SoapMethodNameMap;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.QueryRelationshipsByTypeDocument;
+import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.QueryRelationshipsByTypeResponseDocument;
+
+import javax.xml.namespace.QName;
+
+/**
+ * This class should be generated on every "generation" against the WSDL.
+ * This will ensure it is always up-to-date with the WSDL.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public abstract class AbstractWeatherstationService
+ implements org.apache.ws.resource.handler.WsrfService, org.apache.ws.resource.properties.v2004_06.porttype.GetMultipleResourcePropertiesPortType, org.apache.ws.resource.properties.v2004_06.porttype.GetResourcePropertyPortType, org.apache.ws.notification.base.v2004_06.porttype.NotificationProducerPortType
+{
+
+ public static final String TARGET_NSURI = "http://everest-weather.org/wsdm/samples/2005/04/schema";
+ public static final String TARGET_NSPREFIX = "schema";
+
+ /**
+ * DOCUMENT_ME
+ */
+ private ServiceSoapMethodNameMap m_methodNameMap;
+
+ /**
+ * DOCUMENT_ME
+ */
+ private boolean m_isInitialized;
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestQname DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public String getMethodName(QName requestQname)
+ {
+ if (!m_isInitialized)
+ {
+ init();
+ }
+
+ return m_methodNameMap.getMethodName(requestQname);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public abstract ResourceContext getResourceContext();
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ public final SoapMethodNameMap getMethodNameMap()
+ {
+ return m_methodNameMap;
+ }
+
+ /**
+ * DOCUMENT_ME
+ */
+ public void init()
+ {
+ m_methodNameMap = new ServiceSoapMethodNameMap(getResourceContext());
+ m_isInitialized = true;
+ }
+
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @return DOCUMENT_ME
+ */
+ protected final boolean isInitialized()
+ {
+ return m_isInitialized;
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetMultipleResourcePropertiesResponseDocument getMultipleResourceProperties(org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetMultipleResourcePropertiesDocument requestDoc)
+ {
+ return new org.apache.ws.resource.properties.v2004_06.porttype.impl.GetMultipleResourcePropertiesPortTypeImpl(getResourceContext()).getMultipleResourceProperties(requestDoc);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyResponseDocument getResourceProperty(org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.GetResourcePropertyDocument requestDoc)
+ {
+ return new org.apache.ws.resource.properties.v2004_06.porttype.impl.GetResourcePropertyPortTypeImpl(getResourceContext()).getResourceProperty(requestDoc);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeResponseDocument subscribe(org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.SubscribeDocument requestDoc)
+ {
+ return new org.apache.ws.notification.base.v2004_06.porttype.impl.NotificationProducerPortTypeImpl(getResourceContext()).subscribe(requestDoc);
+ }
+
+ /**
+ * DOCUMENT_ME
+ *
+ * @param requestDoc DOCUMENT_ME
+ * @return DOCUMENT_ME
+ */
+ public org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageResponseDocument getCurrentMessage(org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.GetCurrentMessageDocument requestDoc)
+ {
+ return new org.apache.ws.notification.base.v2004_06.porttype.impl.NotificationProducerPortTypeImpl(getResourceContext()).getCurrentMessage(requestDoc);
+ }
+
+ public QueryRelationshipsByTypeResponseDocument queryRelationshipsByType(QueryRelationshipsByTypeDocument requestDoc)
+ {
+ return new RelationshipsCapabilityImpl(getResourceContext()).queryRelationshipsByType(requestDoc);
+ }
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationCustomOperationsPortType.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationCustomOperationsPortType.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationCustomOperationsPortType.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationCustomOperationsPortType.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,12 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+/**
+ * Custom operations portType.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public interface WeatherstationCustomOperationsPortType
+{
+
+
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationHome.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationHome.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationHome.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationHome.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,128 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import org.apache.ws.resource.Resource;
+import org.apache.ws.resource.ResourceContext;
+import org.apache.ws.resource.ResourceContextException;
+import org.apache.ws.resource.ResourceException;
+import org.apache.ws.resource.ResourceKey;
+import org.apache.ws.resource.ResourceUnknownException;
+import org.apache.ws.resource.example.InteropConstants;
+import org.apache.ws.resource.impl.AbstractResourceHome;
+import org.apache.ws.addressing.EndpointReference;
+
+import javax.xml.namespace.QName;
+import java.io.Serializable;
+
+/**
+ * Home for Weatherstation WS-Resources.
+ */
+public class WeatherstationHome
+ extends AbstractWeatherstationHome
+ implements Serializable
+{
+ /**
+ * The service endpoint name as registered with the SOAP Platform. This is useful for building EPR's. *
+ */
+ public static final QName SERVICE_NAME = javax.xml.namespace.QName.valueOf("{http://everest-weather.org/wsdm/samples/2005/04/schema}weatherstation");
+
+ /**
+ * The management PortType associated with this resource. This is useful for building EPR's.*
+ */
+ public static final QName PORT_TYPE = javax.xml.namespace.QName.valueOf("{http://everest-weather.org/wsdm/samples/2005/04/schema}WeatherStationPortType");
+
+ /**
+ * The WSDL Port name associated with the resource. This is useful for building EPR's. *
+ */
+ public static final String PORT_NAME = "weatherstation";
+
+ /**
+ * The name of the resource key for this resource. *
+ */
+ public static final QName RESOURCE_KEY_NAME = javax.xml.namespace.QName.valueOf("{http://everest-weather.org/wsdm/samples/2005/04/schema}ResourceID");
+
+ /**
+ * A NamespaceVerionHolder which maintains the QNames of Spec Wsdls
+ */
+ public static final org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl SPEC_NAMESPACE_SET = new org.apache.ws.muws.v1_0.impl.WsdmNamespaceVersionHolderImpl();
+ /**
+ * A constant for the JNDI Lookup name for this home. *
+ */
+ public static final String HOME_LOCATION =
+ org.apache.ws.resource.JndiConstants.CONTEXT_NAME_SERVICES + "/" + SERVICE_NAME.getLocalPart() + "/" + org.apache.ws.resource.JndiConstants.ATOMIC_NAME_HOME;
+
+
+ /**
+ * TODO
+ *
+ * @param resourceContext DOCUMENT_ME
+ * @return DOCUMENT_ME
+ * @throws ResourceException DOCUMENT_ME
+ * @throws ResourceContextException DOCUMENT_ME
+ * @throws ResourceUnknownException DOCUMENT_ME
+ */
+ public Resource getInstance(ResourceContext resourceContext)
+ throws ResourceException,
+ ResourceContextException,
+ ResourceUnknownException
+ {
+ ResourceKey key = resourceContext.getResourceKey();
+ WeatherstationResource resource = null;
+ try
+ {
+ resource = (WeatherstationResource)find(key);
+ }
+ catch (ResourceException re)
+ {
+ Object id = key.getValue();
+ /**
+ * Determine if the passed-in key is, in fact, something we expect.
+ */
+ if (id.equals(InteropConstants.WEATHERSTATION_KEY1) || id.equals(InteropConstants.WEATHERSTATION_KEY2))
+ {
+ try
+ {
+ resource = (WeatherstationResource)createInstance(key);
+ FCCIDDocument fccidDocument = FCCIDDocument.Factory.newInstance();
+ //set the same value for both instances
+ fccidDocument.setFCCID(InteropConstants.FCCID);
+ ((WeatherstationResource) resource).setFCCID(fccidDocument);
+ EndpointReference epr = getEndpointReference(resourceContext.getBaseURL( ) + "/" + getServiceName().getLocalPart() , key, SPEC_NAMESPACE_SET.getAddressingNamespace());
+ resource.setEndpointReference(epr);
+
+ }
+ catch (Exception e)
+ {
+ throw new ResourceException(e);
+ }
+ add(key, resource);
+ }
+ else
+ {
+ throw new ResourceUnknownException(id,
+ resourceContext.getServiceName());
+ }
+ }
+ return resource;
+
+ }
+
+ public QName getServiceName()
+ {
+ return SERVICE_NAME;
+ }
+
+ public QName getPortType()
+ {
+ return PORT_TYPE;
+ }
+
+ public String getServicePortName()
+ {
+ return PORT_NAME;
+ }
+
+ public QName getResourceKeyNameQName()
+ {
+ return RESOURCE_KEY_NAME;
+ }
+}
Added: webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java?rev=220138&view=auto
==============================================================================
--- webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java (added)
+++ webservices/muse/trunk/src/examples/interop/src/java/org/everestWeather/wsdm/samples/x2005/x04/schema/WeatherstationPropertyQNames.java Thu Jul 21 09:37:14 2005
@@ -0,0 +1,49 @@
+package org.everestWeather.wsdm.samples.x2005.x04.schema;
+
+import javax.xml.namespace.QName;
+
+/**
+ * QNames of the resource properties defined by Weatherstation WSDL.
+ * <p/>
+ * NOTE: This class is generated and is NOT meant to be modified.
+ */
+public interface WeatherstationPropertyQNames
+{
+
+ QName CORRELATABLEPROPERTIES =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part1.xsd", "CorrelatableProperties", "muws-xs1");
+ QName MANAGEABILITYCAPABILITY =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part1.xsd", "ManageabilityCapability", "muws-xs1");
+ QName FCCID =
+ new QName("http://everest-weather.org/wsdm/samples/2005/04/schema", "FCCID", "wsws-xs");
+ QName RESOURCEID =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part1.xsd", "ResourceId", "muws-xs1");
+ QName OPERATIONALSTATUS =
+ new QName("http://docs.oasis-open.org/wsdm/2004/12/muws/wsdm-muws-part2.xsd", "OperationalStatus", "muws-xs2");
+ 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");
+
+ 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");
+
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: muse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: muse-dev-help@ws.apache.org