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/03/07 03:44:22 UTC
svn commit: r383753 - in
/webservices/sandesha/trunk/samples/src/sandesha2/samples/interop:
AsyncEchoClient.java AsyncPingClient.java SyncEchoClient.java
SyncPingClient.java
Author: chamikara
Date: Mon Mar 6 18:44:20 2006
New Revision: 383753
URL: http://svn.apache.org/viewcvs?rev=383753&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
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=383753&r1=383752&r2=383753&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncEchoClient.java Mon Mar 6 18:44:20 2006
@@ -52,13 +52,14 @@
private String ackPort = "9070";
private String toPort = "8070";
+
private String transportToPort = "8070";
private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMInteropService";
private String transportToEPR = "http://" + toIP + ":" + transportToPort + "/axis2/services/RMInteropService";
- private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/" + "__ANONYMOUS_SERVICE__";
+ //private String acksToEPR = "http://" + ackIP + ":" + ackPort + "/axis2/services/" + "__ANONYMOUS_SERVICE__";
private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
@@ -96,7 +97,9 @@
clientOptions.setProperty(Options.COPY_PROPERTIES,new Boolean (true));
clientOptions.setTo(new EndpointReference (toEPR));
- clientOptions.setProperty(Sandesha2ClientAPI.AcksTo,acksToEPR);
+
+ String acksTo = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP).getAddress();
+ clientOptions.setProperty(Sandesha2ClientAPI.AcksTo,acksTo);
String sequenceKey = "sequence4";
clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,sequenceKey);
@@ -130,7 +133,9 @@
Callback callback4 = new TestCallback ("Callback 4");
serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo4",sequenceKey),callback4);
- clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ Options newOptions = new Options (clientOptions);
+ newOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ serviceClient.setOptions(newOptions);
Callback callback5 = new TestCallback ("Callback 5");
serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo5",sequenceKey),callback5);
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=383753&r1=383752&r2=383753&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/AsyncPingClient.java Mon Mar 6 18:44:20 2006
@@ -27,6 +27,7 @@
import org.apache.axis2.client.ServiceClient;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.sandesha2.Sandesha2Constants;
import org.apache.sandesha2.client.Sandesha2ClientAPI;
import org.apache.ws.commons.om.OMAbstractFactory;
import org.apache.ws.commons.om.OMElement;
@@ -70,7 +71,7 @@
new AsyncPingClient().run();
}
- public void run () throws AxisFault {
+ private void run () throws AxisFault {
if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
return;
@@ -101,9 +102,10 @@
serviceClient.fireAndForget(getPingOMBlock("ping1"));
serviceClient.fireAndForget(getPingOMBlock("ping2"));
- clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ Options newOptions = new Options (clientOptions);
+ newOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ serviceClient.setOptions(newOptions);
serviceClient.fireAndForget(getPingOMBlock("ping3"));
-
}
private static OMElement getPingOMBlock(String text) {
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=383753&r1=383752&r2=383753&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncEchoClient.java Mon Mar 6 18:44:20 2006
@@ -27,6 +27,7 @@
import org.apache.axis2.client.async.Callback;
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.sandesha2.Sandesha2Constants;
import org.apache.sandesha2.client.Sandesha2ClientAPI;
import org.apache.ws.commons.om.OMAbstractFactory;
import org.apache.ws.commons.om.OMElement;
@@ -107,7 +108,9 @@
Callback callback2 = new TestCallback ("Callback 2");
serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo2",sequenceKey),callback2);
- clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ Options newOptions = new Options (clientOptions);
+ newOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ serviceClient.setOptions(newOptions);
Callback callback3 = new TestCallback ("Callback 3");
serviceClient.sendReceiveNonblocking(getEchoOMBlock("echo3",sequenceKey),callback3);
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=383753&r1=383752&r2=383753&view=diff
==============================================================================
--- webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java (original)
+++ webservices/sandesha/trunk/samples/src/sandesha2/samples/interop/SyncPingClient.java Mon Mar 6 18:44:20 2006
@@ -27,8 +27,9 @@
import org.apache.axis2.context.ConfigurationContext;
import org.apache.axis2.context.ConfigurationContextFactory;
import org.apache.axis2.context.MessageContextConstants;
-import org.apache.axis2.description.ParameterImpl;
+import org.apache.sandesha2.SandeshaException;
import org.apache.sandesha2.client.Sandesha2ClientAPI;
+import org.apache.sandesha2.client.SequenceReport;
import org.apache.ws.commons.om.OMAbstractFactory;
import org.apache.ws.commons.om.OMElement;
import org.apache.ws.commons.om.OMFactory;
@@ -69,7 +70,7 @@
new SyncPingClient ().run();
}
- public void run () throws AxisFault {
+ private void run () throws AxisFault {
if ("<SANDESHA2_HOME>".equals(SANDESHA2_HOME)){
System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
@@ -82,7 +83,9 @@
clientOptions.setProperty(MessageContextConstants.TRANSPORT_URL,transportToEPR);
clientOptions.setProperty(Options.COPY_PROPERTIES, new Boolean (true));
clientOptions.setTo(new EndpointReference (toEPR));
- clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,"sequence1");
+
+ String sequenceKey = "sequence1";
+ clientOptions.setProperty(Sandesha2ClientAPI.SEQUENCE_KEY,sequenceKey);
// clientOptions.setProperty(MessageContextConstants.CHUNKED,Constants.VALUE_FALSE); //uncomment this to send messages without chunking.
@@ -91,9 +94,6 @@
// clientOptions.setProperty(Sandesha2ClientAPI.RM_SPEC_VERSION,Sandesha2Constants.SPEC_VERSIONS.WSRX); //uncomment this to send the messages according to the WSRX spec.
ServiceClient serviceClient = new ServiceClient (configContext,null);
- clientOptions.setProperty("prop1","test1234");
- serviceClient.getAxisService().addParameter (new ParameterImpl ("prop2","test12345"));
-
serviceClient.engageModule(new QName ("sandesha2")); //engaging the sandesha2 module.
serviceClient.setOptions(clientOptions);
@@ -101,9 +101,33 @@
serviceClient.fireAndForget(getPingOMBlock("ping1"));
serviceClient.fireAndForget(getPingOMBlock("ping2"));
- clientOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ Options newOptions = new Options (clientOptions);
+ newOptions.setProperty(Sandesha2ClientAPI.LAST_MESSAGE, "true");
+ serviceClient.setOptions(newOptions);
+
serviceClient.fireAndForget(getPingOMBlock("ping31"));
+ SequenceReport sequenceReport = null;
+
+ try {
+ sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(toEPR,sequenceKey,configContext);
+ } catch (SandeshaException e1) {
+ //no data available.
+ }
+
+// while (sequenceReport==null || sequenceReport.getSequenceStatus()!=SequenceReport.SEQUENCE_STATUS_COMPLETED) {
+// try {
+// sequenceReport = Sandesha2ClientAPI.getOutgoingSequenceReport(toEPR,sequenceKey,configContext);
+// } catch (SandeshaException e) {
+// try {
+// Thread.sleep(1000);
+// } catch (InterruptedException e1) {
+// e1.printStackTrace();
+// }
+// }
+// }
+
+ serviceClient.finalizeInvoke();
}
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