Author: ips
Date: Tue Apr 5 16:06:53 2005
New Revision: 160238
URL: http://svn.apache.org/viewcvs?view=rev&rev=160238
Log:
various
Modified:
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/WebServicesMgmtTestCase.java
Modified:
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java
URL:
http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java?view=diff&r1=160237&r2=160238
==============================================================================
---
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java
(original)
+++
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/ServiceStub.java
Tue Apr 5 16:06:53 2005
@@ -18,13 +18,13 @@
import org.apache.ws.util.XmlBeanUtils;
import org.apache.ws.util.soap.SoapClient;
import org.apache.xmlbeans.XmlObject;
-import org.apache.xmlbeans.XmlDouble;
+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.xmlsoap.schemas.soap.envelope.Envelope;
import org.xmlsoap.schemas.soap.envelope.EnvelopeDocument;
import org.xmlsoap.schemas.ws.x2004.x08.addressing.EndpointReferenceType;
-import org.everest.GetCurrentTemperatureDocument;
import java.net.URI;
import java.net.URL;
@@ -59,11 +59,11 @@
GetCurrentTemperatureDocument requestDoc =
GetCurrentTemperatureDocument.Factory.newInstance();
requestDoc.addNewGetCurrentTemperature();
XmlObject response = sendRequest( requestDoc,
"http://xyz.com/action/GetCurrentTemperature"; );
- if ( ! ( response instanceof XmlDouble ) )
+ if ( ! ( response instanceof
GetCurrentTemperatureResponseDocument.GetCurrentTemperatureResponse ) )
{
throw new FaultException( response.toString() );
}
- return ((XmlDouble)response).getDoubleValue();
+ return
((GetCurrentTemperatureResponseDocument.GetCurrentTemperatureResponse)response).getGetCurrentTemperatureResult();
}
private EnvelopeDocument createEnvelope()
Modified:
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/WebServicesMgmtTestCase.java
URL:
http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/WebServicesMgmtTestCase.java?view=diff&r1=160237&r2=160238
==============================================================================
---
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/WebServicesMgmtTestCase.java
(original)
+++
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/WebServicesMgmtTestCase.java
Tue Apr 5 16:06:53 2005
@@ -16,6 +16,7 @@
package org.apache.ws.muws.interop.client;
import org.apache.ws.addressing.XmlBeansEndpointReference;
+import org.apache.ws.mows.v1_0.MowsConstants;
import org.apache.ws.mows.v1_0.capability.EndpointIdentificationCapability;
import org.apache.ws.mows.v1_0.capability.EndpointMetricsCapability;
import org.apache.ws.mows.v1_0.capability.RequestProcessingStateCapability;
@@ -26,8 +27,10 @@
import org.apache.ws.muws.v1_0.capability.MetricsCapability;
import org.apache.ws.muws.v1_0.capability.RelationshipsCapability;
import org.apache.ws.util.XmlBeanUtils;
+import org.apache.ws.util.test.PortListen;
import org.apache.xmlbeans.XmlAnyURI;
import org.apache.xmlbeans.XmlDateTime;
+import org.apache.xmlbeans.XmlException;
import org.apache.xmlbeans.XmlObject;
import org.apache.xmlbeans.XmlQName;
import org.apache.xmlbeans.XmlString;
@@ -35,7 +38,9 @@
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.IntegerCounter;
+import
org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.RequestProcessingNotificationDocument;
import
org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.CorrelatablePropertiesType;
+import
org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventType;
import
org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipParticipantType;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart2.RelationshipType;
import org.xmlsoap.schemas.ws.x2003.x03.addressing.EndpointReferenceDocument;
@@ -177,11 +182,24 @@
performMuwsStatusAct( m_resource );
}
- public void testMowsRequestProcessingNotification() throws FaultException
+ public void testMowsRequestProcessingNotification() throws FaultException,
XmlException
{
XmlObject[] capabilityElems = m_resource.getResourceProperty(
ManageabilityCharacteristicsCapability.PROP_NAME_MANAGEABILITY_CAPABILITY );
assertContainsURI( capabilityElems,
RequestProcessingStateCapability.URI );
- // TODO: subscribe to mows-events:RequestProcessingObservations topic
and validate that events are received
+
+ m_resource.subscribe( s_consumerURL, new QName(
MowsConstants.NSURI_MOWS_TOPICS, "RequestProcessingObservations",
MowsConstants.NSPREFIX_MOWS_TOPICS ) );
+
+ PortListen notifListener = new PortListen( NOTIF_LISTENER_PORT,
NOTIF_LISTENER_TIMEOUT );
+
+ m_service.getCurrentTemperature();
+
+ ManagementEventType mgmtEvent = waitForManagementEvent( notifListener
);
+
+ XmlObject[] requestProcessingNotifElems =
XmlBeanUtils.getChildElements(mgmtEvent, new
QName(MowsConstants.NSURI_MOWS_SCHEMA,
"RequestProcessingNotification",MowsConstants.NSPREFIX_MOWS_SCHEMA));
+ assertEquals( 1, requestProcessingNotifElems.length );
+ assertTrue( requestProcessingNotifElems[0] instanceof
RequestProcessingNotificationDocument.RequestProcessingNotification );
+ RequestProcessingNotificationDocument.RequestProcessingNotification
requestProcessingNotif =
(RequestProcessingNotificationDocument.RequestProcessingNotification)
requestProcessingNotifElems[0];
+ assertTrue( requestProcessingNotif.validate() );
}
public void testMuwsRelationships() throws FaultException
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
