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 ip...@apache.org on 2005/04/08 00:26:25 UTC
svn commit: r160482 - in incubator/muse/trunk/src/site/content/interop/src:
java/org/everest/ test/org/apache/ws/muws/interop/client/
Author: ips
Date: Thu Apr 7 15:26:22 2005
New Revision: 160482
URL: http://svn.apache.org/viewcvs?view=rev&rev=160482
Log:
oops
Added:
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/
- copied from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/AbstractWeatherStationSoapResource.java
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/AbstractWeatherStationSoapResource.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/AbstractWeatherStationSoapService.java
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/AbstractWeatherStationSoapService.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapCustomOperationsPortType.java
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapCustomOperationsPortType.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapHome.java
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapHome.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapResource.java
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapResource.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java
- copied, changed from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoap_deploy.wsdd
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoap_deploy.wsdd
incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoap_jndi-config.xml
- copied unchanged from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoap_jndi-config.xml
Modified:
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java
incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/WebServicesMgmtTestCase.java
Copied: incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java (from r160476, incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java)
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java?view=diff&rev=160482&p1=incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java&r1=160476&p2=incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java&r2=160482
==============================================================================
--- incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java (original)
+++ incubator/muse/trunk/src/site/content/interop/src/java/org/everest/WeatherStationSoapService.java Thu Apr 7 15:26:22 2005
@@ -1,180 +1,172 @@
package org.everest;
-import org.apache.ws.resource.ResourceContext;
-import org.apache.ws.resource.Resource;
-import org.apache.ws.resource.ResourceException;
-import org.apache.ws.resource.impl.SimpleTypeResourceKey;
-import org.apache.ws.resource.example.InteropConstants;
-import org.apache.ws.util.XmlBeanUtils;
+import org.apache.ws.XmlObjectWrapper;
import org.apache.ws.mows.v1_0.MowsConstants;
-import org.apache.ws.notification.topics.Topic;
+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.muws.v1_0.MuwsConstants;
-import org.apache.ws.muws.impl.CategoryImpl;
-import org.apache.ws.XmlObjectWrapper;
+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.WeatherstationPropertyQNames;
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.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 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.RequestProcessingNotificationDocument;
+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.mows.wsdmMows.MessageContentType;
-import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.AnyXmlContentsType;
+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.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventDocument;
+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 javax.naming.InitialContext;
-import javax.naming.NamingException;
+import javax.xml.namespace.QName;
import java.util.ArrayList;
-import java.util.List;
import java.util.Calendar;
+import java.util.List;
/**
- * 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.
- *
- * NOTE: This class is generated. However, it will not be overwritten by subsequent
- * calls to the code generator.
- *
+ * 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
+ extends AbstractWeatherStationSoapService
+ implements WeatherStationSoapCustomOperationsPortType
{
- private ResourceContext m_resourceContext;
+ 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;
- }
+ /**
+ * Creates a new {@link WeatherStationSoapService } object.
+ *
+ * @param resourceContext DOCUMENT_ME
+ */
+ public WeatherStationSoapService( ResourceContext resourceContext )
+ {
+ m_resourceContext = resourceContext;
+ init();
+ }
- public GetManageabilityReferencesResponseDocument getManageabilityReferences(GetManageabilityReferencesDocument request)
+ /**
+ * 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");
+ 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);
+ 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);
+ 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);
+ attributedURI.setStringValue(
+ InteropConstants.SERVICES_URL + "/" + InteropConstants.WEATHERSTATION_SERVICE_NAME );
referencePropertiesType = endpointReferenceType2.addNewReferenceProperties();
- key1 = XmlBeanUtils.addChildElement(referencePropertiesType,resourceKeyName);
- XmlBeanUtils.setValue(key1, InteropConstants.WEATHERSTATION_KEY2);
+ key1 = XmlBeanUtils.addChildElement( referencePropertiesType, resourceKeyName );
+ XmlBeanUtils.setValue( key1, InteropConstants.WEATHERSTATION_KEY2 );
return getManageabilityReferencesResponseDocument;
}
- public org.everest.GetCurrentTemperatureResponseDocument GetCurrentTemperature( org.everest.GetCurrentTemperatureDocument requestDoc )
- {
- 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);
- List topicPath = new ArrayList();
- topicPath.add("RequestProcessingObservations");
- Topic topic = resource.getTopicSpaceSet().getTopicSpace(MowsConstants.NSURI_MOWS_TOPICS).getTopic(topicPath);
- Calendar time = Calendar.getInstance();
-
- //RequestProcessingNotification
- RequestProcessingNotificationDocument notifDocument = RequestProcessingNotificationDocument.Factory.newInstance();
- RequestProcessingNotificationDocument.RequestProcessingNotification notif = notifDocument.addNewRequestProcessingNotification();
-
- //reply message
- MessageInformationType replyInformationType = notif.addNewReply();
- MessageContentType replyMessage = replyInformationType.addNewMessage();
- AnyXmlContentsType anyXmlContentsType = replyMessage.addNewXml();
- XmlBeanUtils.addChildElement(anyXmlContentsType,getCurrentTemperatureResponseDocument);
-
- //request message
- MessageInformationType requestInformationType = notif.addNewRequest();
- MessageContentType requestMessage = requestInformationType.addNewMessage();
- AnyXmlContentsType requestanyXmlContentsType = requestMessage.addNewXml();
- XmlBeanUtils.addChildElement(requestanyXmlContentsType,requestDoc);
-
-
- //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(time);
- notif.setCurrentTime(time);
-
- Situation situation = new SituationImpl(new CategoryImpl(MuwsConstants.SITUATION_OTHER));
- XmlBeansManagementEvent xme = new XmlBeansManagementEvent(situation);
- ManagementEventDocument me = (ManagementEventDocument) ((XmlObjectWrapper)xme).getXmlObject();
- org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.ManagementEventType managementEvent = me.getManagementEvent();
- XmlBeanUtils.addChildElement(managementEvent, notifDocument);
-
- topic.publish(me);
- }
- catch (NamingException e)
- {
- e.printStackTrace();
- }
- catch (ResourceException e)
- {
- e.printStackTrace();
- }
- catch (Exception e)
- {
- e.printStackTrace();
- }
-
-
- return getCurrentTemperatureResponseDocument;
- }
-
-
+ 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 );
+ List topicPath = new ArrayList();
+ topicPath.add( "RequestProcessingObservations" );
+ Topic topic = resource.getTopicSpaceSet().getTopicSpace( MowsConstants.NSURI_MOWS_TOPICS ).getTopic(
+ topicPath );
+ 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;
+ }
+
}
Modified: incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java
URL: http://svn.apache.org/viewcvs/incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java?view=diff&r1=160481&r2=160482
==============================================================================
--- incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java (original)
+++ incubator/muse/trunk/src/site/content/interop/src/test/org/apache/ws/muws/interop/client/AbstractWsdmInteropTestCase.java Thu Apr 7 15:26:22 2005
@@ -25,19 +25,23 @@
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.EnvelopeDocument;
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
@@ -45,9 +49,9 @@
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;
+ 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 = Boolean.getBoolean( "debug" );
@@ -93,14 +97,16 @@
throws FaultException
{
XmlObject[] propElems = resource.getResourceProperty( propName );
- assertEquals( "Incorrect number of " + propName.getPrefix() + ":" + propName.getLocalPart() + " property elements -", 1, propElems.length );
+ 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} );
+ resource.updateResourceProperty( new XmlObject[]{propElem} );
}
protected void assertContainsURI( XmlObject[] capabilityPropElems, String uri )
@@ -122,7 +128,9 @@
* Reads a wsa03:EndpointReference XML document from the specified URL.
*
* @param url
+ *
* @return
+ *
* @throws Exception
*/
protected EndpointReferenceDocument getEndpointReference( URL url ) throws Exception
@@ -136,39 +144,74 @@
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);
+ 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
+ if ( ResourceStub.USE_WRAPPED_NOTIFICATIONS ) //wrapped
{
//get notify
- XmlObject bodyElems[] = XmlBeanUtils.getChildElements(body, new QName(BaseNotification1_2Constants.NSURI_WSNT_SCHEMA, "Notify"));
- assertEquals("The SOAP Body does not contain exactly one wsnt:Notify element.", 1, bodyElems.length);
+ XmlObject bodyElems[] = XmlBeanUtils.getChildElements( body,
+ new QName( BaseNotification1_2Constants.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);
+ 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);
+ 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);
+ 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);
+ 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);
+ 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);
+ 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;
}
}
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=160481&r2=160482
==============================================================================
--- 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 Thu Apr 7 15:26:22 2005
@@ -33,6 +33,7 @@
import org.apache.xmlbeans.XmlObject;
import org.apache.xmlbeans.XmlQName;
import org.apache.xmlbeans.XmlString;
+import org.apache.xmlbeans.XmlOptions;
import org.everestWeather.wsdm.samples.x2005.x04.schema.WeatherstationPropertyQNames;
import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.DurationMetric;
import org.oasisOpen.docs.wsdm.x2004.x12.mows.wsdmMows.EndpointDescriptionsDocument;
@@ -196,12 +197,15 @@
m_service.getCurrentTemperature();
ManagementEventType mgmtEvent = waitForManagementEvent( notifListener );
+ if ( DEBUG ) { System.out.println( "Received ManagementEvent:\n" + mgmtEvent.xmlText( new XmlOptions().setSaveOuter().setSavePrettyPrint() ) ); }
- XmlObject[] requestProcessingNotifElems = XmlBeanUtils.getChildElements(mgmtEvent, new QName(MowsConstants.NSURI_MOWS_SCHEMA, "RequestProcessingNotification",MowsConstants.NSPREFIX_MOWS_SCHEMA));
+ 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() );
+
+ System.out.println( requestProcessingNotif.xmlText( new XmlOptions().setSaveOuter().setSavePrettyPrint() ) );
+ assertTrue( validate( requestProcessingNotif ) );
}
public void testMuwsRelationships() throws FaultException
---------------------------------------------------------------------
To unsubscribe, e-mail: muse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: muse-dev-help@ws.apache.org