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 2006/02/22 04:57:25 UTC
svn commit: r379671 - in
/webservices/sandesha/trunk/samples/src/sandesha2/samples:
interop/AsyncEchoClient.java interop/AsyncPingClient.java
interop/SyncEchoClient.java interop/SyncPingClient.java
simpleServer/SimpleSandesha2Server.java
Author: chamikara
Date: Tue Feb 21 19:57:23 2006
New Revision: 379671
URL: http://svn.apache.org/viewcvs?rev=379671&view=rev
Log:
Updated samples
Modified:
webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java
webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java
webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java
webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java
webservices/sandesha/trunk/samples/src/sandesha2/samples/simpleServer/SimpleSandesha2Server.java
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java?rev=379671&r1=379670&r2=379671&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java Tue Feb 21 19:57:23 2006
@@ -86,8 +86,7 @@
ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
- ServiceClient serviceClient = new ServiceClient (configContext,null);
-
+ ServiceClient serviceClient = new ServiceClient (configContext,null);
Options clientOptions = new Options ();
@@ -106,7 +105,7 @@
//clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE);
//clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
String offeredSequenceID = SandeshaUtil.getUUID();
- //clientOptions.setProperty(Sandesha2ClientAPI.OFFERED_SEQUENCE_ID,offeredSequenceID); //Optional
+ clientOptions.setProperty(Sandesha2ClientAPI.OFFERED_SEQUENCE_ID,offeredSequenceID); //Optional
Callback callback1 = new TestCallback ("Callback 1");
serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo1"),callback1);
@@ -119,8 +118,8 @@
serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo4"),callback4);
clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
- Callback callback5 = new TestCallback ("Callback 5");
- serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo5"),callback5);
+ Callback callback5 = new TestCallback ("Callback 6");
+ serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo6"),callback5);
while (!callback5.isComplete()) {
Thread.sleep(1000);
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java?rev=379671&r1=379670&r2=379671&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java Tue Feb 21 19:57:23 2006
@@ -34,6 +34,7 @@
import org.apache.ws.commons.om.OMElement;
import org.apache.ws.commons.om.OMFactory;
import org.apache.ws.commons.om.OMNamespace;
+import org.apache.ws.commons.soap.SOAP12Constants;
import org.apache.sandesha2.client.Sandesha2ClientAPI;
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java?rev=379671&r1=379670&r2=379671&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java Tue Feb 21 19:57:23 2006
@@ -40,7 +40,6 @@
import org.apache.sandesha2.client.Sandesha2ClientAPI;
import org.apache.sandesha2.util.SandeshaUtil;
-import sandesha2.samples.interop.AsyncEchoClient.TestCallback;
public class SyncEchoClient {
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java?rev=379671&r1=379670&r2=379671&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java Tue Feb 21 19:57:23 2006
@@ -32,6 +32,8 @@
import org.apache.axis2.context.ConfigurationContextFactory;
import org.apache.axis2.context.MessageContextConstants;
import org.apache.axis2.description.AxisService;
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ParameterImpl;
import org.apache.axis2.engine.AxisConfiguration;
import org.apache.axis2.engine.MessageReceiver;
import org.apache.ws.commons.om.OMAbstractFactory;
@@ -39,6 +41,7 @@
import org.apache.ws.commons.om.OMFactory;
import org.apache.ws.commons.om.OMNamespace;
import org.apache.ws.commons.soap.SOAP11Constants;
+import org.apache.ws.commons.soap.SOAP12Constants;
import org.apache.sandesha2.client.Sandesha2ClientAPI;
@@ -84,16 +87,19 @@
Options clientOptions = new Options ();
clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
- // clientOptions.setr\
+
clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
clientOptions.setTo(new EndpointReference (toEPR));
clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1");
- // clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE);
-
+ //clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE);
+ //clientOptions.setSoapVersionURI(SOAP12Constants.SOAP_ENVELOPE_NAMESPACE_URI);
ServiceClient serviceClient = new ServiceClient (configContext,null);
//serviceClient.
+ clientOptions.setProperty("prop1","test1234");
+ serviceClient.getAxisService().addParameter (new ParameterImpl ("prop2","test12345"));
+
serviceClient.engageModule(new QName ("sandesha2"));
serviceClient.setOptions(clientOptions);
@@ -101,7 +107,7 @@
serviceClient.fireAndForget(getPingOMBlock("ping2"));
clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
- serviceClient.fireAndForget(getPingOMBlock("ping3"));
+ serviceClient.fireAndForget(getPingOMBlock("ping31"));
}
Modified: webservices/sandesha/trunk/samples/src/sandesha2/samples/simpleServer/SimpleSandesha2Server.java
URL: http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/src/sandesha2/samples/simpleServer/SimpleSandesha2Server.java?rev=379671&r1=379670&r2=379671&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/simpleServer/SimpleSandesha2Server.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/simpleServer/SimpleSandesha2Server.java Tue Feb 21 19:57:23 2006
@@ -19,6 +19,8 @@
import java.io.File;
import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
import org.apache.axis2.transport.http.SimpleHTTPServer;
public class SimpleSandesha2Server {
@@ -45,7 +47,9 @@
System.out.println("Starting sandesha2 server...");
String axis2_xml = AXIS2_SERVER_PATH + "axis2.xml";
- SimpleHTTPServer server = new SimpleHTTPServer (AXIS2_SERVER_PATH,axis2_xml,8080);
+ ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_SERVER_PATH,axis2_xml);
+
+ SimpleHTTPServer server = new SimpleHTTPServer (configContext,8080);
server.start();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org