You are viewing a plain text version of this content. The canonical link for it is here.
Posted to fx-dev@ws.apache.org by ch...@apache.org on 2005/11/21 03:53:31 UTC
svn commit: r345816 - in
/webservices/sandesha/trunk/interop/src/org/apache/sandesha2/interop/microsoft:
MicrosoftAsyncEchoClient.java MicrosoftAsyncPingClient.java
MicrosoftSyncPingClient.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org