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/12/01 10:10:29 UTC
svn commit: r350214 - in /webservices/sandesha/trunk/samples: conf/interop/
src/org/apache/sandesha2/samples/interop/clients/
Author: chamikara
Date: Thu Dec 1 01:10:01 2005
New Revision: 350214
URL: http://svn.apache.org/viewcvs?rev=350214&view=rev
Log:
Changes due to recent changes of Axis2 client API (addition of Options)
Modified:
webservices/sandesha/trunk/samples/conf/interop/services.xml
webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncEchoClient.java
webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncPingClient.java
webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncEchoClient.java
webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncPingClient.java
Modified: webservices/sandesha/trunk/samples/conf/interop/services.xml
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/conf/interop/services.xml?rev=350214&r1=350213&r2=350214&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/conf/interop/services.xml (original)
+++ webservices/sandesha/trunk/samples/conf/interop/services.xml Thu Dec 1 01:10:01 2005
@@ -1,4 +1,4 @@
-<service name="OneWayService">
+<service name="RMInteropService">
<parameter name="ServiceClass" locked="xsd:false">org.apache.sandesha2.samples.interop.service.RMInteropService</parameter>
<module ref="sandesha"/>
Modified: webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncEchoClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncEchoClient.java?rev=350214&r1=350213&r2=350214&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncEchoClient.java (original)
+++ webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncEchoClient.java Thu Dec 1 01:10:01 2005
@@ -20,16 +20,19 @@
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.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;
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;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
import org.apache.sandesha2.util.SandeshaUtil;
public class AsyncEchoClient {
@@ -42,7 +45,7 @@
private String ackPort = "9070";
- private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/InteropService";
+ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService";
private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/AnonymousService/echoString";
@@ -50,11 +53,11 @@
private String AXIS2_CLIENT_PATH = SANDESHA2_HOME + "\\target\\client\\"; //this will be available after a maven build
- public static void main(String[] args) throws AxisFault {
+ public static void main(String[] args) throws Exception {
new AsyncEchoClient ().run();
}
- private void run () throws AxisFault {
+ private void run () throws Exception {
if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
return;
@@ -62,28 +65,39 @@
Call call = new Call(AXIS2_CLIENT_PATH);
call.engageModule(new QName("sandesha"));
- //call.set(Constants.SANDESHA_DEBUG_MODE,"on");
- call.set(Constants.AcksTo,acksToEPR); //Optional
- call.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
- call.setTo(new EndpointReference(toEPR));
- call.set(Constants.SEQUENCE_KEY,"sequence1"); //Optional
- call.setSoapAction("test:soap:action");
- call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID()); //Optional
- call.setTransportInfo(org.apache.axis2.Constants.TRANSPORT_HTTP,org.apache.axis2.Constants.TRANSPORT_HTTP,true);
+
+ Options clientOptions = new Options ();
+ clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true));
+ call.setClientOptions(clientOptions);
+ //call.set(Sandesha2Constants.SANDESHA_DEBUG_MODE,"on");
+ clientOptions.setProperty(ClientAPI.AcksTo,acksToEPR);
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+ clientOptions.setTo(new EndpointReference(toEPR));
+ clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,toEPR);
+ clientOptions.setProperty(ClientAPI.SEQUENCE_KEY,"sequence1"); //Optional
+ clientOptions.setSoapAction("test:soap:action");
+ clientOptions.setProperty(ClientAPI.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID()); //Optional
+ clientOptions.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.LAST_MESSAGE, "true");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
Callback callback3 = new TestCallback ("Callback 3");
call.invokeNonBlocking("echoString", getEchoOMBlock("echo3"),callback3);
+
+ while (!callback3.isComplete()) {
+ Thread.sleep(1000);
+ }
+
+ call.close();
}
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);
+ OMNamespace defaultNS = fac.createOMNamespace("http://tempuri.apache.org","ns1");
+ OMElement echoElement = fac.createOMElement("echoString", null);
+ OMElement paramElement = fac.createOMElement("text", null);
echoElement.addChild(paramElement);
paramElement.setText(text);
Modified: webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncPingClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncPingClient.java?rev=350214&r1=350213&r2=350214&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/AsyncPingClient.java Thu Dec 1 01:10:01 2005
@@ -19,14 +19,17 @@
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.MessageSender;
+import org.apache.axis2.client.MessageSender;
+import org.apache.axis2.client.Options;
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;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
public class AsyncPingClient {
@@ -39,7 +42,7 @@
private String ackPort = "9070";
- private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/InteropService";
+ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService";
private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/AnonymousService/echoString";
@@ -58,15 +61,18 @@
}
MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH);
- sender.set(Constants.AcksTo,acksToEPR);
- sender.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
- sender.setSoapAction("aaaaa");
+ Options clientOptions = new Options ();
+ clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true));
+ clientOptions.setSenderTransportProtocol(Constants.TRANSPORT_HTTP);
+ sender.setClientOptions(clientOptions);
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+ clientOptions.setProperty(ClientAPI.AcksTo,acksToEPR);
sender.engageModule(new QName ("sandesha"));
- sender.setTo(new EndpointReference(toEPR));
- sender.set(Constants.SEQUENCE_KEY,"sequence1");
+ clientOptions.setTo(new EndpointReference(toEPR));
+ clientOptions.setProperty(ClientAPI.SEQUENCE_KEY,"sequence1");
sender.send("ping",getPingOMBlock("ping1"));
sender.send("ping",getPingOMBlock("ping2"));
- sender.set(Constants.LAST_MESSAGE, "true");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
sender.send("ping",getPingOMBlock("ping3"));
}
Modified: webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncEchoClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncEchoClient.java?rev=350214&r1=350213&r2=350214&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncEchoClient.java (original)
+++ webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncEchoClient.java Thu Dec 1 01:10:01 2005
@@ -19,18 +19,21 @@
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
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.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.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.axis2.soap.SOAPConstants;
-import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
import org.apache.sandesha2.util.SandeshaUtil;
public class SyncEchoClient {
@@ -39,7 +42,7 @@
private String toPort = "8070";
- private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/InteropService";
+ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService";
private String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
@@ -57,24 +60,27 @@
Call call = new Call(AXIS2_CLIENT_PATH);
call.engageModule(new QName("sandesha"));
- call.setTo(new EndpointReference(toEPR));
- call.set(Constants.SEQUENCE_KEY,"sequence1"); //Optional
- //call.set(Constants.SANDESHA_DEBUG_MODE,"on");
- call.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
- call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID()); //Optional
- call.setTransportInfo(org.apache.axis2.Constants.TRANSPORT_HTTP,org.apache.axis2.Constants.TRANSPORT_HTTP,true);
+ Options clientOptions = new Options ();
+ clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true));
+ clientOptions.setSenderTransportProtocol(Constants.TRANSPORT_HTTP);
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+ call.setClientOptions(clientOptions);
+ clientOptions.setTo(new EndpointReference(toEPR));
+ clientOptions.setProperty(ClientAPI.SEQUENCE_KEY,"sequence1");
+ clientOptions.setProperty(ClientAPI.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
+ clientOptions.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.LAST_MESSAGE, "true");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
Callback callback3 = new TestCallback ("Callback 3");
call.invokeNonBlocking("echoString", getEchoOMBlock("echo3"),callback3);
}
private static OMElement getEchoOMBlock(String text) {
OMFactory fac = OMAbstractFactory.getOMFactory();
- OMNamespace defaultNS = fac.createOMNamespace("",null);
+ OMNamespace defaultNS = fac.createOMNamespace("http://tempuri.apache.org","ns1");
OMElement echoElement = fac.createOMElement("echoString", defaultNS);
OMElement paramElement = fac.createOMElement("text", defaultNS);
echoElement.addChild(paramElement);
@@ -89,6 +95,10 @@
public TestCallback (String name) {
this.name = name;
+ }
+
+ public String toString () {
+ return name;
}
public void onComplete(AsyncResult result) {
Modified: webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncPingClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncPingClient.java?rev=350214&r1=350213&r2=350214&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/org/apache/sandesha2/samples/interop/clients/SyncPingClient.java Thu Dec 1 01:10:01 2005
@@ -19,17 +19,20 @@
import javax.xml.namespace.QName;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
import org.apache.axis2.addressing.EndpointReference;
-import org.apache.axis2.clientapi.MessageSender;
+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.SOAP11Constants;
import org.apache.axis2.soap.SOAP12Constants;
-import org.apache.sandesha2.Constants;
+import org.apache.sandesha2.Sandesha2Constants;
+import org.apache.sandesha2.Sandesha2Constants.ClientAPI;
-import com.ibm.wsdl.extensions.soap.SOAPConstants;
public class SyncPingClient {
@@ -37,7 +40,7 @@
private String toPort = "8070";
- private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/InteropService";
+ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService";
private String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
@@ -56,14 +59,21 @@
MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH);
sender.engageModule(new QName ("sandesha"));
- //sender.set(Constants.SANDESHA_DEBUG_MODE,"on");
- sender.setTo(new EndpointReference(toEPR));
- sender.set(Constants.SEQUENCE_KEY,"sequence1");
- sender.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+ //sender.set(Sandesha2Constants.SANDESHA_DEBUG_MODE,"on");
+ Options clientOptions = new Options ();
+ sender.setClientOptions(clientOptions);
+
+ clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true));
+ clientOptions.setSenderTransportProtocol(Constants.TRANSPORT_HTTP);
+ clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
+
+ clientOptions.setTo(new EndpointReference(toEPR));
+ clientOptions.setProperty(ClientAPI.SEQUENCE_KEY,"sequence1");
sender.send("ping",getPingOMBlock("ping1"));
sender.send("ping",getPingOMBlock("ping2"));
- sender.set(Constants.LAST_MESSAGE, "true");
+ clientOptions.setProperty(ClientAPI.LAST_MESSAGE, "true");
sender.send("ping",getPingOMBlock("ping3"));
+
}
private static OMElement getPingOMBlock(String text) {
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org