Author: chamikara
Date: Sun Nov 20 18:53:12 2005
New Revision: 345816
URL: http://svn.apache.org/viewcvs?rev=345816&view=rev
Log:
To comply with the recent changes 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=345816&r1=345815&r2=345816&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
Sun Nov 20 18:53:12 2005
@@ -20,10 +20,11 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.AsyncResult;
-import org.apache.axis2.clientapi.Call;
-import org.apache.axis2.clientapi.Callback;
-import org.apache.axis2.clientapi.MessageSender;
+import org.apache.axis2.client.AsyncResult;
+import org.apache.axis2.client.Call;
+import org.apache.axis2.client.Callback;
+import org.apache.axis2.client.MessageSender;
+import org.apache.axis2.context.MessageContextConstants;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
@@ -35,11 +36,13 @@
public class MicrosoftAsyncEchoClient {
private static String to =
"http://131.107.72.15/ReliableMessaging_Service_Indigo/ReliableRequestReplyDual.svc";;
// IP: 131.107.153.195 port:80
- private static String replyTo =
"http://localhost:9070/axis/services/RMSampleService";;
+ private static String transportTo =
"http://127.0.0.1:8070/ReliableMessaging_Service_Indigo/ReliableRequestReplyDual.svc";;
+
+ //private static String replyTo =
"http://localhost:9080/axis/services/RMSampleService";;
private static String SANDESHA_HOME = "<SANDESHA2_HOME>"; //Change this
to ur path.
- private static String AXIS2_CLIENT_PATH = SANDESHA_HOME +
"target\\client\\"; //this will be available after a maven build
+ private static String AXIS2_CLIENT_PATH = SANDESHA_HOME +
"\\target\\client\\"; //this will be available after a maven build
public static void main(String[] args) throws AxisFault {
new MicrosoftAsyncEchoClient ().run();
@@ -48,31 +51,38 @@
private void run () throws AxisFault {
Call call = new Call(AXIS2_CLIENT_PATH);
call.engageModule(new QName("sandesha"));
-
call.set(Constants.AcksTo,"http://203.94.94.136:9080/axis2/services/AnonymousService/echoString";);
//Optional
+
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);
- //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.set(Constants.SANDESHA_DEBUG_MODE,"on");
+ call.setWsaAction("urn:wsrm:EchoString");
+ call.setSoapAction("urn:wsrm:EchoString");
+
+// 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.set(Constants.LAST_MESSAGE, "true");
Callback callback3 = new TestCallback ("Callback 3");
- call.invokeNonBlocking("EchoString",
getEchoOMBlock("echo3"),callback3);
+ call.invokeNonBlocking("echoString",
getEchoOMBlock("echo3"),callback3);
}
private static OMElement getEchoOMBlock(String text) {
OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace defaultNS = fac.createOMNamespace("",null);
- OMElement echoElement = fac.createOMElement("echoString",
defaultNS);
- OMElement paramElement = fac.createOMElement("text", defaultNS);
- echoElement.addChild(paramElement);
- paramElement.setText(text);
-
+ OMNamespace ns =
fac.createOMNamespace("http://tempuri.org/","ns1";);
+ OMElement echoElement = fac.createOMElement("echoString", ns);
+ OMElement param1Element = fac.createOMElement("Text", ns);
+ OMElement param2Element = fac.createOMElement("Sequence", ns);
+ echoElement.addChild(param1Element);
+ echoElement.addChild(param2Element);
+ param1Element.setText(text);
+ param2Element.setText("sequenceid");
return echoElement;
}
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=345816&r1=345815&r2=345816&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
Sun Nov 20 18:53:12 2005
@@ -20,7 +20,8 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.MessageSender;
+import org.apache.axis2.client.MessageSender;
+import org.apache.axis2.context.MessageContextConstants;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
@@ -39,6 +40,8 @@
private static String to =
"http://131.107.72.15/ReliableMessaging_Service_Indigo/ReliableOneWayDual.svc";;
//IP : 131.107.153.195 Port:80
+ private static String transportTo =
"http://127.0.0.1:8070/ReliableMessaging_Service_Indigo/ReliableOneWayDual.svc";;
+
private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change
this to ur path.
private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME +
"\\target\\client\\"; //this will be available after a maven build
@@ -60,25 +63,26 @@
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(Constants.AcksTo,"http://203.94.94.136:9080/axis2/services/AnonymousService/echoString";);
- sender.setReplyTo(new EndpointReference
("http://203.94.94.136:9080/axis2/services/AnonymousService/echoString";));
- sender.setFaultTo(new EndpointReference
("http://203.94.94.136:9080/axis2/services/AnonymousService/echoString";));
+ 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");
- //sender.send("ping",getPingOMBlock("ping1"));
- //sender.send("ping",getPingOMBlock("ping2"));
+ sender.send("ping",getPingOMBlock("Microsoft-1"));
+ sender.send("ping",getPingOMBlock("Microsoft-2"));
sender.set(Constants.LAST_MESSAGE, "true");
- sender.send("ping",getPingOMBlock("ping3"));
+ sender.send("ping",getPingOMBlock("Microsoft-3"));
}
private static OMElement getPingOMBlock(String text) {
OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace ns =
fac.createOMNamespace("http://tempuri.apache.org";,
+ OMNamespace ns = fac.createOMNamespace("http://tempuri.org/";,
"ns1");
OMNamespace defautNS = fac.createOMNamespace("",null);
OMElement pingElement = fac.createOMElement("Ping", ns);
- OMElement paramElement = fac.createOMElement("Text", defautNS);
+ OMElement paramElement = fac.createOMElement("Text", ns);
pingElement.addChild(paramElement);
paramElement.setText(text);
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=345816&r1=345815&r2=345816&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
Sun Nov 20 18:53:12 2005
@@ -20,8 +20,9 @@
import org.apache.axis2.AxisFault;
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.MessageSender;
+import org.apache.axis2.client.MessageSender;
import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.MessageContextConstants;
import org.apache.axis2.om.OMAbstractFactory;
import org.apache.axis2.om.OMElement;
import org.apache.axis2.om.OMFactory;
@@ -34,7 +35,9 @@
public class MicrosoftSyncPingClient {
private static String to =
"http://131.107.72.15/ReliableMessaging_Service_Indigo/ReliableOneWay.svc";;
//IP : 131.107.153.195 Port:80
-
+
+ private static String transportTo =
"http://127.0.0.1:8070/ReliableMessaging_Service_Indigo/ReliableOneWay.svc";;
+
private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change
this to ur path.
private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME +
"\\target\\client\\"; //this will be available after a maven build
@@ -56,24 +59,26 @@
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");
- //sender.send("ping",getPingOMBlock("ping1"));
- //sender.send("ping",getPingOMBlock("ping2"));
+ sender.send("ping",getPingOMBlock("Microsoft-1"));
+ sender.send("ping",getPingOMBlock("Microsoft-2"));
sender.set(Constants.LAST_MESSAGE, "true");
- sender.send("ping",getPingOMBlock("ping3"));
+ sender.send("ping",getPingOMBlock("Microsoft-3"));
}
private static OMElement getPingOMBlock(String text) {
OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace ns =
fac.createOMNamespace("http://tempuri.apache.org";,
+ OMNamespace ns = fac.createOMNamespace("http://tempuri.org/";,
"ns1");
OMNamespace defautNS = fac.createOMNamespace("",null);
OMElement pingElement = fac.createOMElement("Ping", ns);
- OMElement paramElement = fac.createOMElement("Text", defautNS);
+ OMElement paramElement = fac.createOMElement("Text", ns);
pingElement.addChild(paramElement);
paramElement.setText(text);
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
