You are viewing a plain text version of this content. The canonical link for it is here.
Posted to muse-commits@ws.apache.org by wi...@apache.org on 2005/10/04 20:42:23 UTC
svn commit: r294895 - in /webservices/muse/trunk/client/src/java: ./
org/apache/ws/client/muse/client/ org/apache/ws/client/muse/client/impl/
org/apache/ws/client/muse/client/impl/notification/
org/apache/ws/client/muse/client/impl/wsrf/ org/apache/ws/...
Author: wire
Date: Tue Oct 4 11:42:03 2005
New Revision: 294895
URL: http://svn.apache.org/viewcvs?rev=294895&view=rev
Log:
Added Subscription Manager and renames SetPropertiesRequest class to ProeprtiesList
Added:
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/PropertiesList.java
- copied, changed from r292825, webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SetPropertiesRequest.java
Removed:
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SetPropertiesRequest.java
Modified:
webservices/muse/trunk/client/src/java/Sample.java
webservices/muse/trunk/client/src/java/Sample2.java
webservices/muse/trunk/client/src/java/WsdmExplorer.java
webservices/muse/trunk/client/src/java/log4j.properties
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/ManageableResource.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/NotificationConsumer.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/ManageableResourceImpl.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/ChangeNotificationImpl.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/QueryImpl.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/SubscriptionManagerImpl.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/TopicExpressionImpl.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/wsrf/SetPropertiesRequestImpl.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/ChangeNotification.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Notification.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Query.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SubscriptionManager.java
webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/TopicExpression.java
Modified: webservices/muse/trunk/client/src/java/Sample.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/Sample.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/Sample.java (original)
+++ webservices/muse/trunk/client/src/java/Sample.java Tue Oct 4 11:42:03 2005
@@ -4,7 +4,7 @@
import javax.xml.namespace.QName;
import org.apache.ws.client.muse.client.ManageableResource;
-import org.apache.ws.client.muse.client.model.SetPropertiesRequest;
+import org.apache.ws.client.muse.client.model.PropertiesList;
public class Sample {
QName NAME = new QName( "http://ws.apache.org/service/testresource", "Name", "tns");
@@ -27,7 +27,7 @@
public void setNameOfResource() throws Exception{
ManageableResource managedResource = ManageableResource.Factory.create(null, eprURL);
- SetPropertiesRequest spr=SetPropertiesRequest.Factory.create();
+ PropertiesList spr=PropertiesList.Factory.create();
spr.addUpdateRequest(NAME,new String[]{"New Name"});
managedResource.setProperties(spr);
}
Modified: webservices/muse/trunk/client/src/java/Sample2.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/Sample2.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/Sample2.java (original)
+++ webservices/muse/trunk/client/src/java/Sample2.java Tue Oct 4 11:42:03 2005
@@ -19,6 +19,7 @@
import org.apache.ws.client.muse.client.model.SubscriptionManager;
import org.apache.ws.client.muse.client.model.TopicExpression;
import org.apache.xmlbeans.XmlException;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionResponseDocument;
public class Sample2 implements Observer {
@@ -144,4 +145,11 @@
String text = notification.getNotificationMessage().toString();
}
+
+ public static void main(String[] args) {
+ PauseSubscriptionResponseDocument responseDoc = PauseSubscriptionResponseDocument.Factory.newInstance( );
+ responseDoc.addNewPauseSubscriptionResponse( );
+ //return responseDoc;
+ System.out.println();
+ }
}
Modified: webservices/muse/trunk/client/src/java/WsdmExplorer.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/WsdmExplorer.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/WsdmExplorer.java (original)
+++ webservices/muse/trunk/client/src/java/WsdmExplorer.java Tue Oct 4 11:42:03 2005
@@ -26,7 +26,8 @@
import org.apache.ws.client.muse.client.impl.exceptions.FaultException;
import org.apache.ws.client.muse.client.impl.exceptions.UnexpectedServerResponseException;
import org.apache.ws.client.muse.client.model.Notification;
-import org.apache.ws.client.muse.client.model.SetPropertiesRequest;
+import org.apache.ws.client.muse.client.model.PropertiesList;
+import org.apache.ws.client.muse.client.model.SubscriptionManager;
import org.apache.ws.client.muse.client.model.TopicExpression;
import org.apache.xmlbeans.XmlException;
import org.apache.xmlbeans.XmlObject;
@@ -124,7 +125,8 @@
}});
consumer.start();
System.out.println("Now listening on "+consumer.getEndpointReference().getAddress()+" to Topic "+name);
- ManageableResource subscription=m_resource.subscribe(TopicExpression.Factory.create(null,name),consumer.getEndpointReference());
+ SubscriptionManager subscription = m_resource.subscribe(TopicExpression.Factory.create(null,name),consumer.getEndpointReference());
+ subscription.pauseSubscription();
System.out.println("Hit any key to destroy your subscription.\n Until then all notifications received will be written here.");
System.in.read();
subscription.destroy();
@@ -192,7 +194,7 @@
String setValue = this.args[3];
System.out.println("Setting Property "+name);
- SetPropertiesRequest spr=SetPropertiesRequest.Factory.create();
+ PropertiesList spr=PropertiesList.Factory.create();
spr.addUpdateRequest(name,new String[]{setValue});
m_resource.setProperties(spr);
System.out.println("has been set to "+setValue);
Modified: webservices/muse/trunk/client/src/java/log4j.properties
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/log4j.properties?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/log4j.properties (original)
+++ webservices/muse/trunk/client/src/java/log4j.properties Tue Oct 4 11:42:03 2005
@@ -15,7 +15,7 @@
# Root logger's log-level (affects all classes within the JVM that use Log4J) #
#-------------------------------------------------------------------------------#
#
-log4j.rootCategory=DEBUG, STDOUT
+log4j.rootCategory=INFO, STDOUT
log4j.additivity.rootCategory=false
#--------------------------------------------------#
@@ -30,10 +30,10 @@
#
# Log-levels for Apache packages...
#
-log4j.category.org.apache=INFO
+log4j.category.org.apache=INFOs
org.apache.commons.i18n=INFO
log4j.category.org.apache.axis=INFO
-log4j.category.org.apache.axis.transport.http.SimpleAxisServer=DEBUG
+log4j.category.org.apache.axis.transport.http.SimpleAxisServer=INFO
log4j.category.org.apache.axis.wsdl.toJava.JavaGeneratorFactory=WARN
#-------------------------------------------#
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/ManageableResource.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/ManageableResource.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/ManageableResource.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/ManageableResource.java Tue Oct 4 11:42:03 2005
@@ -30,7 +30,7 @@
import org.apache.ws.client.muse.client.impl.notification.NotifyableResourceImpl;
import org.apache.ws.client.muse.client.model.Notification;
import org.apache.ws.client.muse.client.model.Query;
-import org.apache.ws.client.muse.client.model.SetPropertiesRequest;
+import org.apache.ws.client.muse.client.model.PropertiesList;
import org.apache.ws.client.muse.client.model.SubscriptionManager;
import org.apache.ws.client.muse.client.model.TopicExpression;
import org.apache.xmlbeans.XmlException;
@@ -244,6 +244,23 @@
public abstract void destroy() throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
/**
+ * Updates the contents for the QName component into the
+ * resource properties document to be the equivalent string of the passed in
+ * XML Object. This object must be expected in the schema for the resource properties
+ * document.
+ * <b>Note:</b> this operation may not be supported by this resource.
+ * A resource must implement SetResourceProperties for this method to work.
+ * @return
+ * @throws FaultException
+ * @throws URISyntaxException
+ * @throws IOException
+ * @throws XmlException
+ * @throws UnexpectedServerResponseException
+ */
+ public void updateProperty(QName property, XmlObject update) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException ;
+
+
+ /**
* Updates the String contents for the QName component into the
* resource properties document.
* <b>Note:</b> this operation may not be supported by this resource.
@@ -433,7 +450,7 @@
* @throws UnexpectedServerResponseException
*/
public abstract XmlObject setProperties(
- SetPropertiesRequest modificationList)
+ PropertiesList modificationList)
throws URISyntaxException, IOException, XmlException,
UnexpectedServerResponseException, FaultException;
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/NotificationConsumer.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/NotificationConsumer.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/NotificationConsumer.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/NotificationConsumer.java Tue Oct 4 11:42:03 2005
@@ -33,17 +33,46 @@
return new NotificationConsumerImpl( port, timeout);
}
}
-
+ /**
+ * Starts the notification consumer listening on the port specified when the consumer was created.
+ * @throws IOException If the port is in use or the sockect could not be created.
+ */
public abstract void start() throws IOException;
+ /**
+ * Shuts down all monitoring threads and closes the notification consumers listnering socket.
+ */
public abstract void stop();
+ /**
+ * Returns the Uri of the last notification received. Can be used to sort notifications
+ * based onthe post URI that they use.
+ * @return A string containing the URI used in the post request.
+ */
public abstract String getRequestUri();
+ /**
+ * Returns a conveniant ERP which can be used in subscribe requests
+ * so that they can send notifications to this consumer.
+ * @return an EndpointReference to this Consumer
+ * @throws UnknownHostException will be thrown if no hostname can be
+ * automatically determined.
+ */
public abstract XmlBeansEndpointReference getEndpointReference()
throws UnknownHostException;
+
+ /**
+ * Any applications that implements Observer can receive notification
+ * when this consumer receives a notification.
+ * @param o An object that implements observer to receive notification
+ */
public void addObserver(Observer o);
- public void deleteObserver(Observer o);
-
+ /**
+ * Allows the removal of an observer that no longer wants to know when a notification
+ * has arrived.
+ * @param o An object that implements observer to receive notification
+ */
+ public void deleteObserver(Observer o);
+
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/ManageableResourceImpl.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/ManageableResourceImpl.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/ManageableResourceImpl.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/ManageableResourceImpl.java Tue Oct 4 11:42:03 2005
@@ -37,7 +37,7 @@
import org.apache.ws.client.muse.client.impl.stubs.ServiceStub;
import org.apache.ws.client.muse.client.impl.wsrf.InsertOrUpdateRequest;
import org.apache.ws.client.muse.client.impl.wsrf.SetPropertiesRequestImpl;
-import org.apache.ws.client.muse.client.model.SetPropertiesRequest;
+import org.apache.ws.client.muse.client.model.PropertiesList;
import org.apache.ws.muws.v1_0.capability.IdentityCapability;
import org.apache.ws.util.XmlBeanUtils;
import org.apache.xmlbeans.XmlCursor;
@@ -452,6 +452,15 @@
return success;
}
+ public void updateProperty(QName property, XmlObject update) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException {
+ String xmlText;
+ XmlOptions opts = new XmlOptions();
+ opts.setSaveOuter();
+ opts.setSavePrettyPrint();
+ xmlText=update.xmlText(opts);
+ updateProperty(property,xmlText);
+ }
+
public void updateProperty(QName property, double newValue) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
String[] updates = {String.valueOf(newValue)};
updateProperty(property, updates);
@@ -514,7 +523,7 @@
/* updateProperties takes a SetPropertiesRequest instance which defines
* Insert, Update and Delete requests and the order in which they were made.
*/
- public XmlObject setProperties(SetPropertiesRequest modificationList) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException {
+ public XmlObject setProperties(PropertiesList modificationList) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException {
//build the SetResourceProperties document
SetResourcePropertiesDocument setPropsDocument =
@@ -661,7 +670,7 @@
}
//helper method to create SetPropertiesRequest instance
- public SetPropertiesRequest createNewSetPropertiesRequest(){
+ public PropertiesList createNewSetPropertiesRequest(){
return new SetPropertiesRequestImpl();
}
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/ChangeNotificationImpl.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/ChangeNotificationImpl.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/ChangeNotificationImpl.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/ChangeNotificationImpl.java Tue Oct 4 11:42:03 2005
@@ -24,7 +24,7 @@
import org.apache.ws.client.muse.client.impl.wsrf.InsertOrUpdateRequest;
import org.apache.ws.client.muse.client.impl.wsrf.SetPropertiesRequestImpl;
import org.apache.ws.client.muse.client.model.ChangeNotification;
-import org.apache.ws.client.muse.client.model.SetPropertiesRequest;
+import org.apache.ws.client.muse.client.model.PropertiesList;
import org.apache.ws.util.XmlBeanUtils;
import org.apache.xmlbeans.XmlObject;
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.impl.ManagementEventTypeImpl;
@@ -57,7 +57,7 @@
public XmlObject[] getNewValuesPayload(){
return XmlBeanUtils.getChildElements(propChange.getNewValue());
}
- public SetPropertiesRequest getOldValues(){
+ public PropertiesList getOldValues(){
SetPropertiesRequestImpl setProp = new SetPropertiesRequestImpl();
XmlObject[] arryVals = getOldValuesPayload();
for (int i = 0; i < arryVals.length; i++) {
@@ -67,7 +67,7 @@
return setProp;
}
- public SetPropertiesRequest getNewValues(){
+ public PropertiesList getNewValues(){
XmlObject[] arryVals = getNewValuesPayload();
SetPropertiesRequestImpl setProp = new SetPropertiesRequestImpl();
for (int i = 0; i < arryVals.length; i++) {
@@ -78,7 +78,7 @@
}
public String getNewValueAsString(){
- SetPropertiesRequest props = getNewValues();
+ PropertiesList props = getNewValues();
if(props.getAllResourcesIndex()>0){
InsertOrUpdateRequest req = (InsertOrUpdateRequest)props.getAllSetResourceRequests().get(0);
return req.getPropetyValues()[0];
@@ -88,7 +88,7 @@
}
public String getOldValueAsString(){
- SetPropertiesRequest props = getOldValues();
+ PropertiesList props = getOldValues();
if(props.getAllResourcesIndex()>0){
InsertOrUpdateRequest req = (InsertOrUpdateRequest)props.getAllSetResourceRequests().get(0);
return req.getPropetyValues()[0];
@@ -98,7 +98,7 @@
}
public QName getNewValueName(){
- SetPropertiesRequest props = getNewValues();
+ PropertiesList props = getNewValues();
if(props.getAllResourcesIndex()>0){
InsertOrUpdateRequest req = (InsertOrUpdateRequest)props.getAllSetResourceRequests().get(0);
return req.getProperty();
@@ -108,7 +108,7 @@
}
public QName getOldValueName(){
- SetPropertiesRequest props = getOldValues();
+ PropertiesList props = getOldValues();
if(props.getAllResourcesIndex()>0){
InsertOrUpdateRequest req = (InsertOrUpdateRequest)props.getAllSetResourceRequests().get(0);
return req.getProperty();
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/QueryImpl.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/QueryImpl.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/QueryImpl.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/QueryImpl.java Tue Oct 4 11:42:03 2005
@@ -16,21 +16,23 @@
package org.apache.ws.client.muse.client.impl.notification;
import org.apache.ws.client.muse.client.model.Query;
+import org.apache.xmlbeans.XmlObject;
import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.QueryExpressionType;
public class QueryImpl implements Query {
-
- public QueryImpl() {
+ XmlObject object;
+ public QueryImpl(QueryExpressionType object) {
super();
- // TODO Auto-generated constructor stub
+ this.object=object;
}
+ public XmlObject getQuery(){ return this.object;}
+ public void setQuery(XmlObject query){ this.object=query;}
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.Query#toXmlObject()
*/
public QueryExpressionType toXmlObject() {
- // TODO Auto-generated method stub
- return null;
+ return (QueryExpressionType)this.object;
}
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/SubscriptionManagerImpl.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/SubscriptionManagerImpl.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/SubscriptionManagerImpl.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/SubscriptionManagerImpl.java Tue Oct 4 11:42:03 2005
@@ -17,15 +17,29 @@
import java.io.IOException;
import java.net.MalformedURLException;
+import java.net.URISyntaxException;
import java.net.URL;
import java.util.Calendar;
import org.apache.ws.addressing.EndpointReference;
+import org.apache.ws.addressing.XmlBeansEndpointReference;
+import org.apache.ws.client.muse.client.impl.exceptions.FaultException;
+import org.apache.ws.client.muse.client.impl.exceptions.UnexpectedServerResponseException;
import org.apache.ws.client.muse.client.model.Query;
import org.apache.ws.client.muse.client.model.SubscriptionManager;
import org.apache.ws.client.muse.client.model.TopicExpression;
+import org.apache.ws.notification.base.v2004_06.porttype.SubscriptionManagerPortType;
+import org.apache.ws.util.XmlBeanUtils;
import org.apache.xmlbeans.XmlException;
import org.apache.xmlbeans.XmlObject;
+import org.apache.xmlbeans.impl.values.XmlDateTimeImpl;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.PauseSubscriptionResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.ResumeSubscriptionResponseDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.impl.TopicExpressionTypeImpl;
+import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.QueryExpressionType;
+import org.xmlsoap.schemas.ws.x2003.x03.addressing.impl.EndpointReferenceTypeImpl;
public class SubscriptionManagerImpl extends NotifyableResourceImpl implements SubscriptionManager {
@@ -44,81 +58,161 @@
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#getConsumerReference()
*/
- public EndpointReference getConsumerReference(){
- return epr;
+ public EndpointReference getConsumerReference() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ XmlObject[] ret = getProperty(SubscriptionManagerPortType.PROP_QNAME_CONSUMER_REFERENCE);
+ if(ret.length<1)
+ throw new UnexpectedServerResponseException("There were no parts the SOAP response. An EPR could not be created.");
+ if(!(ret[0] instanceof EndpointReferenceTypeImpl))
+ throw new UnexpectedServerResponseException("Expected an EndpointReferenceType in the response document but did not find one.");
+ EndpointReferenceTypeImpl impl=(EndpointReferenceTypeImpl)ret[0];
+ return new XmlBeansEndpointReference(impl);
}
+
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#getTopicExpression()
*/
- public TopicExpression getTopicExpression(){
- return null;}
+ public TopicExpression getTopicExpression() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ XmlObject[] ret = getProperty(SubscriptionManagerPortType.PROP_QNAME_TOPIC_EXPRESSION);
+ if(ret.length<1)
+ throw new UnexpectedServerResponseException("There were no parts the SOAP response. A Topic Expression could not be created.");
+ if(!(ret[0] instanceof TopicExpressionTypeImpl))
+ throw new UnexpectedServerResponseException("Expected an TopicExpressionType in the response document but did not find one.");
+ TopicExpressionTypeImpl topicExprImpl = (TopicExpressionTypeImpl)ret[0];
+ TopicExpressionImpl te = new TopicExpressionImpl(XmlBeanUtils.getValueAsQName(topicExprImpl),topicExprImpl.getDialect());
+ return te;
+ }
+
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#isUseNotify()
*/
- public boolean isUseNotify(){
- return false;
+ public boolean isUseNotify() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ return getPropertyAsBoolean(SubscriptionManagerPortType.PROP_QNAME_USE_NOTIFY);
}
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#getPrecondition()
*/
- public Query getPrecondition(){
- return null;
+ public Query getPrecondition() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ XmlObject[] ret = getProperty(SubscriptionManagerPortType.PROP_QNAME_PRECONDITION);
+ if(ret.length<1)
+ throw new UnexpectedServerResponseException("There were no parts in the server response to extract a precondition.");
+ if((ret[0] instanceof QueryExpressionType))
+ throw new UnexpectedServerResponseException("Expected response to contain QueryExpressionType but could not find it.");
+ QueryExpressionType eqt = (QueryExpressionType)ret[0];
+ return new QueryImpl(eqt);
}
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#getSelector()
*/
- public Query getSelector(){
- return null;
+ public Query getSelector() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ XmlObject[] ret = getProperty(SubscriptionManagerPortType.PROP_QNAME_SELECTOR);
+ if(ret.length<1)
+ throw new UnexpectedServerResponseException("There were no parts in the server response to extract a selector.");
+ if((ret[0] instanceof QueryExpressionType))
+ throw new UnexpectedServerResponseException("Expected response to contain QueryExpressionType but could not find it.");
+ QueryExpressionType eqt = (QueryExpressionType)ret[0];
+ return new QueryImpl(eqt);
}
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#getSubscriptionPolicy()
*/
- public XmlObject getSubscriptionPolicy(){
- return null;
+ public XmlObject getSubscriptionPolicy() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ XmlObject[] ret = getProperty(SubscriptionManagerPortType.PROP_QNAME_SUBSCRIPTION_POLICY);
+ if(ret.length<1)
+ throw new UnexpectedServerResponseException("No policy could be found in the response document.");
+ return ret[0];
}
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#getCreationTime()
*/
- public Calendar getCreationTime(){
- return null;
+ public Calendar getCreationTime() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException{
+ XmlObject[] ret = getProperty(SubscriptionManagerPortType.PROP_QNAME_CREATION_TIME);
+ if(ret.length<1)
+ throw new UnexpectedServerResponseException("No information was returned in the response.");
+ if(!(ret[0] instanceof XmlDateTimeImpl))
+ throw new UnexpectedServerResponseException("No DateType Xml was returned in the response.");
+ XmlDateTimeImpl dt=(XmlDateTimeImpl)ret[0];
+ return dt.getCalendarValue();
}
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setConsumerReference(org.apache.ws.addressing.EndpointReference)
*/
- public void setConsumerReference(EndpointReference reference){}
+ public void setConsumerReference(EndpointReference reference) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ XmlBeansEndpointReference xEpr=null;
+ if(reference instanceof XmlBeansEndpointReference){
+ // Best case, preserve epr XML
+ xEpr=(XmlBeansEndpointReference)reference;
+ } else {
+ xEpr=new XmlBeansEndpointReference(reference.getAddress(),org.apache.ws.addressing.v2003_03.AddressingConstants.NSURI_ADDRESSING_SCHEMA);
+ Object[] params = reference.getReferenceParameters();
+ Object[] props = reference.getReferenceProperties();
+ xEpr.setReferenceParameters(params);
+ xEpr.setReferenceProperties(props);
+ }
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_CONSUMER_REFERENCE,xEpr.getXmlObject());
+ }
+
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setTopicExpression(org.apache.ws.client.muse.client.model.TopicExpression)
*/
- public void setTopicExpression(TopicExpression topicExpression){}
+ public void setTopicExpression(TopicExpression topicExpression) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_TOPIC_EXPRESSION,topicExpression.toXmlObject());
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setUseNotify(boolean)
*/
- public void setUseNotify(boolean use){}
+ public void setUseNotify(boolean use) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_USE_NOTIFY,use);
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setPrecondition(org.apache.ws.client.muse.client.model.Query)
*/
- public void setPrecondition(Query precondition){}
+ public void setPrecondition(Query precondition) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_PRECONDITION,precondition.toXmlObject());
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setSelector(org.apache.ws.client.muse.client.model.Query)
*/
- public void setSelector(Query selector){}
+ public void setSelector(Query selector) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_SELECTOR,selector.toXmlObject());
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setSubscriptionPolicy(org.apache.xmlbeans.XmlObject)
*/
- public void setSubscriptionPolicy(XmlObject policy){}
+ public void setSubscriptionPolicy(XmlObject policy) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ //
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_SUBSCRIPTION_POLICY,policy);
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#setCreationTime(java.util.Calendar)
*/
- public void setCreationTime(Calendar subsciptionTime){}
+ public void setCreationTime(Calendar subsciptionTime) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ XmlDateTimeImpl dt = new XmlDateTimeImpl();
+ dt.setCalendarValue(subsciptionTime);
+ updateProperty(SubscriptionManagerPortType.PROP_QNAME_CREATION_TIME,dt);
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#pauseSubscription()
*/
- public void pauseSubscription(){}
+ public void pauseSubscription() throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ PauseSubscriptionDocument document = PauseSubscriptionDocument.Factory.newInstance();
+ document.addNewPauseSubscription();
+ XmlObject response = rs.sendRequest(document,"http://xyz.com/action/PauseSubscription");
+ if (!(response instanceof PauseSubscriptionResponseDocument.PauseSubscriptionResponse)) {
+ throw new FaultException(response.toString());
+ }
+ }
/* (non-Javadoc)
* @see org.apache.ws.client.muse.client.impl.notification.SubscriptionManager#resumeSubscription()
*/
- public void resumeSubscription(){}
+ public void resumeSubscription() throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException{
+ ResumeSubscriptionDocument document = ResumeSubscriptionDocument.Factory.newInstance();
+ document.addNewResumeSubscription();
+ XmlObject response = rs.sendRequest(document,"http://xyz.com/action/ResumeSubscription");
+ if (!(response instanceof ResumeSubscriptionResponseDocument.ResumeSubscriptionResponse)) {
+ throw new FaultException(response.toString());
+ }
+ }
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/TopicExpressionImpl.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/TopicExpressionImpl.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/TopicExpressionImpl.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/notification/TopicExpressionImpl.java Tue Oct 4 11:42:03 2005
@@ -18,6 +18,10 @@
import javax.xml.namespace.QName;
import org.apache.ws.client.muse.client.model.TopicExpression;
+import org.apache.ws.util.XmlBeanUtils;
+import org.apache.xmlbeans.XmlObject;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.TopicExpressionDocument;
+import org.oasisOpen.docs.wsn.x2004.x06.wsnWSBaseNotification12Draft01.TopicExpressionType;
public class TopicExpressionImpl implements TopicExpression {
private QName name;
@@ -61,6 +65,14 @@
public String toString() {
// TODO Auto-generated method stub
return "Name="+name+", Dialect="+dialect ;
+ }
+
+ public XmlObject toXmlObject(){
+ TopicExpressionDocument doc=TopicExpressionDocument.Factory.newInstance();
+ TopicExpressionType te = doc.addNewTopicExpression();
+ te.setDialect(getDialect());
+ XmlBeanUtils.setValueAsQName(te,getName());
+ return (XmlObject)te;
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/wsrf/SetPropertiesRequestImpl.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/wsrf/SetPropertiesRequestImpl.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/wsrf/SetPropertiesRequestImpl.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/impl/wsrf/SetPropertiesRequestImpl.java Tue Oct 4 11:42:03 2005
@@ -21,10 +21,10 @@
import javax.xml.namespace.QName;
-import org.apache.ws.client.muse.client.model.SetPropertiesRequest;
+import org.apache.ws.client.muse.client.model.PropertiesList;
-public class SetPropertiesRequestImpl implements SetPropertiesRequest{
+public class SetPropertiesRequestImpl implements PropertiesList{
//Stores all setResource requests(Insert,Update,Delete) in order
public ArrayList allSetResourceRequests = new ArrayList();
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/ChangeNotification.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/ChangeNotification.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/ChangeNotification.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/ChangeNotification.java Tue Oct 4 11:42:03 2005
@@ -20,12 +20,48 @@
import org.apache.xmlbeans.XmlObject;
public interface ChangeNotification {
+ /**
+ * Low level access to the contents of the old values field.
+ * @return Returns a raw XmlObject list of the list of old property values.
+ */
public XmlObject[] getOldValuesPayload();
+ /**
+ * Low level access to the contents of the new values field.
+ * @return Returns a raw XmlObject list of the list of new property values.
+ */
public XmlObject[] getNewValuesPayload();
- public SetPropertiesRequest getOldValues();
- public SetPropertiesRequest getNewValues();
+ /**
+ * Returns a lists of the old values of a set of changed properties.
+ * @return a list of changed properties
+ */
+ public PropertiesList getOldValues();
+ /**
+ * Returns a lists of the new values of a set of changed properties.
+ * @return a list of changed properties
+ */
+ public PropertiesList getNewValues();
+ /**
+ * Returns a single new value even if more exists. Provided to handle
+ * the simplest single change notifications.
+ * @return A single property value as a string.
+ */
public String getNewValueAsString();
+ /**
+ * Returns a single old value even if more exists. Provided to handle
+ * the simplest single change notifications.
+ * @return A single property value as a string.
+ */
public String getOldValueAsString();
+ /**
+ * Returns a single new property name. Provided to handle
+ * the simplest single change notifications.
+ * @return A single property name as a QName.
+ */
public QName getNewValueName();
+ /**
+ * Returns a single old property name. Provided to handle
+ * the simplest single change notifications.
+ * @return A single property name as a QName.
+ */
public QName getOldValueName();
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Notification.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Notification.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Notification.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Notification.java Tue Oct 4 11:42:03 2005
@@ -25,24 +25,57 @@
import org.oasisOpen.docs.wsdm.x2004.x12.muws.wsdmMuwsPart1.impl.ManagementEventTypeImpl;
public interface Notification {
-
+ /**
+ * An OPTIONAL EndpointReference to the NotificationProducer that
+ * originally generated the NotificationMessage artifact.
+ * @return an Endpoint Reference.
+ */
public abstract EndpointReference getProducerReference();
+ /**
+ * Returns the Notification message as an XML object for low
+ * level xml access.
+ * @return an XmlObject representing the notification
+ */
public abstract XmlObject getNotificationMessage();
// MUWS ----------------------------------------------
+ /**
+ * Returns the management event portion of the notification as an
+ * ManagementEventType XmlObject.
+ */
public abstract ManagementEventTypeImpl getManagementEvent();
+ /**
+ * Retuns the Identification String for this event
+ * @return a unique event identifier
+ */
public abstract String getEventId();
+ /**
+ * The time that this notification was generated.
+ * @return A calendar object containing the time thisnotification was created.
+ */
public abstract Calendar getReportTime();
+ /**
+ * Identifies who sent this notification.
+ * @return Returns a list of components reponsible for this message.
+ */
public abstract ComponentType getSourceComponent();
+ /**
+ * Returns the resource identifier for the componetn originating
+ * this message.
+ * @return A string containg a resource id.
+ */
public abstract String getSourceComponentId();
- // TODO Implementation of this will have to wait until the unit test
+ /**
+ * Returns the address part of the service originating the notification.
+ * @return an array of Source Addresses
+ */
public abstract ComponentAddressType[] getSourceComponentAddresses();
public abstract ComponentType getReporter();
@@ -51,12 +84,33 @@
public abstract ComponentAddressType[] getReporterComponentAddresses();
+ /**
+ * Returns a situation object if a situation was included in the notification.
+ * @return A situation object.
+ * @throws UnexpectedServerResponseException thrown if this notification contained not situation part.
+ */
public abstract Situation getSituation() throws UnexpectedServerResponseException;
+ /**
+ * If the notification contains a change notification it will be returned as an
+ * object.
+ * @return A ChangeNotification object.
+ * @throws UnexpectedServerResponseException will be thrown if the notification did not
+ * contain a changenotification part.
+ */
public abstract ChangeNotification getChangeNotification() throws UnexpectedServerResponseException;
+ /**
+ * Returns a list of XmlObjects that were delivered inside the notification block
+ * of the notification.
+ * @return
+ */
public abstract XmlObject[] getNotificationPayload();
+ /**
+ * Returns the topic that this notification was produced from.
+ * @return a TopicExpression.
+ */
public TopicExpression getTopic();
}
Copied: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/PropertiesList.java (from r292825, webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SetPropertiesRequest.java)
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/PropertiesList.java?p2=webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/PropertiesList.java&p1=webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SetPropertiesRequest.java&r1=292825&r2=294895&rev=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SetPropertiesRequest.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/PropertiesList.java Tue Oct 4 11:42:03 2005
@@ -20,10 +20,15 @@
import javax.xml.namespace.QName;
import org.apache.ws.client.muse.client.impl.wsrf.SetPropertiesRequestImpl;
-
-public interface SetPropertiesRequest {
+/**
+ * Represents a list of properties. Can be used in setting or expressing
+ * what has changed inside of a notification.
+ * @author wire
+ *
+ */
+public interface PropertiesList {
public static class Factory {
- public static SetPropertiesRequest create(){
+ public static PropertiesList create(){
return new SetPropertiesRequestImpl();
}
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Query.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Query.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Query.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/Query.java Tue Oct 4 11:42:03 2005
@@ -15,10 +15,14 @@
*=============================================================================*/
package org.apache.ws.client.muse.client.model;
+import org.apache.xmlbeans.XmlObject;
import org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceProperties12Draft01.QueryExpressionType;
public interface Query {
public abstract QueryExpressionType toXmlObject();
+ public abstract XmlObject getQuery();
+ public abstract void setQuery(XmlObject query);
+
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SubscriptionManager.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SubscriptionManager.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SubscriptionManager.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/SubscriptionManager.java Tue Oct 4 11:42:03 2005
@@ -15,41 +15,46 @@
*=============================================================================*/
package org.apache.ws.client.muse.client.model;
+import java.io.IOException;
+import java.net.URISyntaxException;
import java.util.Calendar;
import org.apache.ws.addressing.EndpointReference;
import org.apache.ws.client.muse.client.ManageableResource;
+import org.apache.ws.client.muse.client.impl.exceptions.FaultException;
+import org.apache.ws.client.muse.client.impl.exceptions.UnexpectedServerResponseException;
+import org.apache.xmlbeans.XmlException;
import org.apache.xmlbeans.XmlObject;
public interface SubscriptionManager extends ManageableResource {
- public abstract EndpointReference getConsumerReference();
+ public abstract EndpointReference getConsumerReference() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract TopicExpression getTopicExpression();
+ public abstract TopicExpression getTopicExpression() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract boolean isUseNotify();
+ public abstract boolean isUseNotify() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract Query getPrecondition();
+ public abstract Query getPrecondition() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract Query getSelector();
+ public abstract Query getSelector() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract XmlObject getSubscriptionPolicy();
+ public abstract XmlObject getSubscriptionPolicy() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract Calendar getCreationTime();
+ public abstract Calendar getCreationTime() throws FaultException, URISyntaxException, IOException, XmlException, UnexpectedServerResponseException;
- public abstract void setConsumerReference(EndpointReference reference);
+ public abstract void setConsumerReference(EndpointReference reference) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
- public abstract void setTopicExpression(TopicExpression topicExpression);
+ public abstract void setTopicExpression(TopicExpression topicExpression) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
- public abstract void setUseNotify(boolean use);
+ public abstract void setUseNotify(boolean use) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
- public abstract void setPrecondition(Query precondition);
+ public abstract void setPrecondition(Query precondition) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
- public abstract void setSelector(Query selector);
+ public abstract void setSelector(Query selector) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
- public abstract void setSubscriptionPolicy(XmlObject policy);
+ public abstract void setSubscriptionPolicy(XmlObject policy) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
- public abstract void setCreationTime(Calendar subsciptionTime);
+ public abstract void setCreationTime(Calendar subsciptionTime) throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
/**
* To temporarily suspend the delivery of NotificationMessages on the given
@@ -59,14 +64,25 @@
* Upon successful processing of this message the Subscription is in the paused
* state. Delivery of NotificationMessages can be resumed by sending the
* ResumeSubscription request message
+ *
+ * @throws FaultException
+ * @throws UnexpectedServerResponseException
+ * @throws XmlException
+ * @throws IOException
+ * @throws URISyntaxException
*/
- public abstract void pauseSubscription();
+ public abstract void pauseSubscription() throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
/**
* If a requestor wishes to resume the delivery of NotificationMessages on
* the given Subscription, it must send a ResumeSubscription request message.
+ * @throws FaultException
+ * @throws UnexpectedServerResponseException
+ * @throws XmlException
+ * @throws IOException
+ * @throws URISyntaxException
*
*/
- public abstract void resumeSubscription();
+ public abstract void resumeSubscription() throws URISyntaxException, IOException, XmlException, UnexpectedServerResponseException, FaultException;
}
Modified: webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/TopicExpression.java
URL: http://svn.apache.org/viewcvs/webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/TopicExpression.java?rev=294895&r1=294894&r2=294895&view=diff
==============================================================================
--- webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/TopicExpression.java (original)
+++ webservices/muse/trunk/client/src/java/org/apache/ws/client/muse/client/model/TopicExpression.java Tue Oct 4 11:42:03 2005
@@ -20,6 +20,7 @@
import javax.xml.namespace.QName;
import org.apache.ws.client.muse.client.impl.notification.TopicExpressionImpl;
+import org.apache.xmlbeans.XmlObject;
public interface TopicExpression {
public static final String MUSE_RESOURCE_VERSION_1_0="MUSE_RESOURCE_VERSION_1_0";
@@ -50,5 +51,8 @@
* @param name The name to set.
*/
public abstract void setName(QName name);
+
+ public XmlObject toXmlObject();
+
}