Author: chamikara
Date: Thu Dec 1 19:55:24 2005
New Revision: 351569
URL: http://svn.apache.org/viewcvs?rev=351569&view=rev
Log:
Some changes due to recent modifications to Axis2
Modified:
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncEchoClient.java
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncPingClient.java
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftSyncPingClient.java
Modified:
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncEchoClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncEchoClient.java?rev=351569&r1=351568&r2=351569&view=diff
==============================================================================
---
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncEchoClient.java
(original)
+++
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncEchoClient.java
Thu Dec 1 19:55:24 2005
@@ -21,7 +21,7 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Call;
-import org.apache.axis2.client.MessageSender;
+import org.apache.axis2.client.Options;
import org.apache.axis2.client.async.AsyncResult;
import org.apache.axis2.client.async.Callback;
import org.apache.axis2.context.MessageContextConstants;
@@ -29,8 +29,7 @@
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
import org.apache.axis2.om.OMNamespace;
-import org.apache.axis2.soap.SOAP12Constants;
-import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
import org.apache.sandesha2.util.SandeshaUtil;
public class MicrosoftAsyncEchoClient {
@@ -50,24 +49,18 @@
private void run () throws AxisFault {
Call call = new Call(AXIS2_CLIENT_PATH);
- call.engageModule(new QName("sandesha"));
-
call.set(Constants.AcksTo,"http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";);
//Optional
-
- call.setTo(new EndpointReference(to));
- call.set(MessageContextConstants.TRANSPORT_URL,transportTo);
- call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
//Optional
-
call.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
-
call.setTransportInfo(org.apache.axis2.Constants.TRANSPORT_HTTP,org.apache.axis2.Constants.TRANSPORT_HTTP,true);
- //call.set(Constants.SANDESHA_DEBUG_MODE,"on");
- call.setWsaAction("urn:wsrm:EchoString");
- call.setSoapAction("urn:wsrm:EchoString");
+ Options clientOptions = new Options ();
+ call.setClientOptions(clientOptions);
-// Callback callback1 = new TestCallback ("Callback 1");
-// call.invokeNonBlocking("echoString",
getEchoOMBlock("echo1"),callback1);
-// Callback callback2 = new TestCallback ("Callback 2");
-// call.invokeNonBlocking("echoString",
getEchoOMBlock("echo2"),callback2);
+ call.engageModule(new QName("sandesha"));
+
clientOptions.setProperty(ClientAPI.AcksTo,"http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";);
//Optional
- call.set(Constants.LAST_MESSAGE, "true");
+ clientOptions.setTo(new EndpointReference(to));
+
clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportTo);
+
clientOptions.setProperty(ClientAPI.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
//Optional
+ clientOptions.setAction("urn:wsrm:EchoString");
+ clientOptions.setSoapAction("urn:wsrm:EchoString");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
Callback callback3 = new TestCallback ("Callback 3");
call.invokeNonBlocking("echoString",
getEchoOMBlock("echo3"),callback3);
}
Modified:
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncPingClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncPingClient.java?rev=351569&r1=351568&r2=351569&view=diff
==============================================================================
---
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncPingClient.java
(original)
+++
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftAsyncPingClient.java
Thu Dec 1 19:55:24 2005
@@ -21,13 +21,13 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.MessageSender;
+import org.apache.axis2.client.Options;
import org.apache.axis2.context.MessageContextConstants;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
import org.apache.axis2.om.OMNamespace;
-import org.apache.axis2.soap.SOAP12Constants;
-import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
/**
* @author chamikara
@@ -58,21 +58,21 @@
}
MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH);
+ Options clientOptions = new Options ();
+ sender.setClientOptions(clientOptions);
sender.engageModule(new QName ("sandesha"));
-
- sender.set(Constants.SANDESHA_DEBUG_MODE,"on"); //Sets the
debug on for sandesha.
-
sender.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
- sender.setTo(new EndpointReference(to));
- sender.set(MessageContextConstants.TRANSPORT_URL,transportTo);
-
sender.set(Constants.AcksTo,"http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";);
- sender.setReplyTo(new EndpointReference
("http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";));
- sender.setFaultTo(new EndpointReference
("http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";));
- sender.set(Constants.SEQUENCE_KEY,"sequence1");
- sender.setSoapAction("urn:wsrm:Ping");
- sender.setWsaAction("urn:wsrm:Ping");
+ clientOptions.setProperty(ClientAPI.SANDESHA_DEBUG_MODE,"on");
//Sets the debug on for sandesha.
+ clientOptions.setTo(new EndpointReference(to));
+
clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportTo);
+
clientOptions.setProperty(ClientAPI.AcksTo,"http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";);
+ clientOptions.setReplyTo(new EndpointReference
("http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";));
+ clientOptions.setFaultTo(new EndpointReference
("http://www-lk.wso2.com:9080/axis2/services/AnonymousService/echoString";));
+ clientOptions.setProperty(ClientAPI.SEQUENCE_KEY,"sequence1");
+ clientOptions.setSoapAction("urn:wsrm:Ping");
+ clientOptions.setAction("urn:wsrm:Ping");
sender.send("ping",getPingOMBlock("Microsoft-1"));
sender.send("ping",getPingOMBlock("Microsoft-2"));
- sender.set(Constants.LAST_MESSAGE, "true");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
sender.send("ping",getPingOMBlock("Microsoft-3"));
}
Modified:
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftSyncPingClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftSyncPingClient.java?rev=351569&r1=351568&r2=351569&view=diff
==============================================================================
---
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftSyncPingClient.java
(original)
+++
webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft/MicrosoftSyncPingClient.java
Thu Dec 1 19:55:24 2005
@@ -21,16 +21,13 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.MessageSender;
-import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.client.Options;
import org.apache.axis2.context.MessageContextConstants;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
import org.apache.axis2.om.OMNamespace;
-import org.apache.axis2.om.impl.llom.OMNamespaceImpl;
-import org.apache.axis2.soap.SOAP12Constants;
-import org.apache.axis2.transport.http.HTTPConstants;
-import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
public class MicrosoftSyncPingClient {
@@ -54,21 +51,18 @@
}
MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH);
+ Options clientOptions = new Options ();
+ sender.setClientOptions(clientOptions);
sender.engageModule(new QName ("sandesha"));
-
- sender.set(Constants.SANDESHA_DEBUG_MODE,"on"); //Sets the
debug on for sandesha.
-
- sender.setTo(new
EndpointReference("http://131.107.72.15/ReliableMessaging_Service_Indigo/ReliableOneWay.svc";));
- sender.set(MessageContextConstants.TRANSPORT_URL,transportTo);
-
-
sender.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
- sender.set(Constants.SEQUENCE_KEY,"sequence1");
-
sender.setSenderTransport(org.apache.axis2.Constants.TRANSPORT_HTTP);
- sender.setSoapAction("urn:wsrm:Ping");
- sender.setWsaAction("urn:wsrm:Ping");
+ clientOptions.setProperty(ClientAPI.SANDESHA_DEBUG_MODE,"on");
//Sets the debug on for sandesha.
+ clientOptions.setTo(new
EndpointReference("http://131.107.72.15/ReliableMessaging_Service_Indigo/ReliableOneWay.svc";));
+
clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportTo);
+ clientOptions.setProperty(ClientAPI.SEQUENCE_KEY,"sequence1");
+ clientOptions.setSoapAction("urn:wsrm:Ping");
+ clientOptions.setAction("urn:wsrm:Ping");
sender.send("ping",getPingOMBlock("Microsoft-1"));
sender.send("ping",getPingOMBlock("Microsoft-2"));
- sender.set(Constants.LAST_MESSAGE, "true");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
sender.send("ping",getPingOMBlock("Microsoft-3"));
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
