Author: wire
Date: Tue Aug 9 13:04:13 2005
New Revision: 231096
URL: http://svn.apache.org/viewcvs?rev=231096&view=rev
Log:
Added destroy subscription
Modified:
webservices/muse/trunk/src/examples/ieeedemo/client/src/org/apache/ws/muws/interop/client/ResourceStub.java
Modified:
webservices/muse/trunk/src/examples/ieeedemo/client/src/org/apache/ws/muws/interop/client/ResourceStub.java
URL:
http://svn.apache.org/viewcvs/webservices/muse/trunk/src/examples/ieeedemo/client/src/org/apache/ws/muws/interop/client/ResourceStub.java?rev=231096&r1=231095&r2=231096&view=diff
==============================================================================
---
webservices/muse/trunk/src/examples/ieeedemo/client/src/org/apache/ws/muws/interop/client/ResourceStub.java
(original)
+++
webservices/muse/trunk/src/examples/ieeedemo/client/src/org/apache/ws/muws/interop/client/ResourceStub.java
Tue Aug 9 13:04:13 2005
@@ -27,6 +27,8 @@
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.wsrfWSResourceLifetime12Draft01.DestroyDocument;
+import
org.oasisOpen.docs.wsrf.x2004.x06.wsrfWSResourceLifetime12Draft01.impl.DestroyResponseDocumentImpl;
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;
@@ -87,13 +89,13 @@
}
}
- public EndpointReference subscribe( String consumerURL, QName topic )
throws FaultException
+ public EndpointReference subscribe( String consumerURL, QName topic,long
duration ) 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() + 7200000);
+ instance.setTimeInMillis(instance.getTimeInMillis() + duration);
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();
@@ -108,6 +110,23 @@
}
SubscribeResponseDocument.SubscribeResponse subscribeResponse =
(SubscribeResponseDocument.SubscribeResponse) response;
return new XmlBeansEndpointReference(
subscribeResponse.getSubscriptionReference() );
+
+ }
+
+ public void destroySubscription( ) throws FaultException
+ {
+ DestroyDocument requestDoc = DestroyDocument.Factory.newInstance();
+ requestDoc.addNewDestroy();
+ XmlObject response = sendRequest( requestDoc,
"http://xyz.com/action/Destroy","D"; );
+ if ( ! ( response instanceof
DestroyResponseDocumentImpl.DestroyResponseImpl) )
+ {
+ throw new FaultException( response.toString() );
+ }
+ }
+
+ public EndpointReference subscribe( String consumerURL, QName topic )
throws FaultException
+ {
+ return subscribe( consumerURL, topic,7200000);
}
private EnvelopeDocument createEnvelope()
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
