You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ch...@apache.org on 2006/12/04 03:15:41 UTC
svn commit: r482013 - in
/webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide:
AsyncEchoClient.java AsyncPingClient.java SyncEchoClient.java
SyncPingClient.java
Author: chamikara
Date: Sun Dec 3 18:15:38 2006
New Revision: 482013
URL: http://svn.apache.org/viewvc?view=rev&rev=482013
Log:
Updated sample client files
Modified:
webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncEchoClient.java
webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncPingClient.java
webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncEchoClient.java
webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncPingClient.java
Modified: webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncEchoClient.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncEchoClient.java?view=diff&rev=482013&r1=482012&r2=482013
==============================================================================
--- webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncEchoClient.java (original)
+++ webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncEchoClient.java Sun Dec 3 18:15:38 2006
@@ -83,6 +83,7 @@
System.out.println("ERROR: Please set the directory you unzipped Sandesha2 as the first option.");
return;
}
+
String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
@@ -121,27 +122,23 @@
serviceClient.setOptions(clientOptions);
-// Callback callback1 = new TestCallback ("Callback 1");
-// serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo1",sequenceKey),callback1);
-//
-// Callback callback2 = new TestCallback ("Callback 2");
-// serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo2",sequenceKey),callback2);
-//
-// Callback callback3 = new TestCallback ("Callback 3");
-// serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo3",sequenceKey),callback3);
-//
-// Callback callback4 = new TestCallback ("Callback 4");
-// serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo4",sequenceKey),callback4);
+ Callback callback1 = new TestCallback ("Callback 1");
+ serviceClient.sendReceiveNonBlocking (getEchoOMBlock("echo1",sequenceKey),callback1);
+
+ Callback callback2 = new TestCallback ("Callback 2");
+ serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo2",sequenceKey),callback2);
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
- Callback callback5 = new TestCallback ("Callback 5");
- serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo5",sequenceKey),callback5);
+ Callback callback3 = new TestCallback ("Callback 3");
+ serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo3",sequenceKey),callback3);
- while (!callback5.isComplete()) {
+ while (!callback1.isComplete() &&
+ !callback2.isComplete() &&
+ !callback3.isComplete()) {
Thread.sleep(1000);
}
- Thread.sleep(4000);
+ Thread.sleep(6000);
configContext.getListenerManager().stop();
serviceClient.cleanup();
Modified: webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncPingClient.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncPingClient.java?view=diff&rev=482013&r1=482012&r2=482013
==============================================================================
--- webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncPingClient.java (original)
+++ webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/AsyncPingClient.java Sun Dec 3 18:15:38 2006
@@ -17,14 +17,10 @@
package sandesha2.samples.userguide;
import java.io.File;
-
-import javax.xml.namespace.QName;
-
import org.apache.axiom.om.OMAbstractFactory;
import org.apache.axiom.om.OMElement;
import org.apache.axiom.om.OMFactory;
import org.apache.axiom.om.OMNamespace;
-import org.apache.axis2.AxisFault;
import org.apache.axis2.Constants;
import org.apache.axis2.addressing.EndpointReference;
import org.apache.axis2.client.Options;
@@ -52,7 +48,7 @@
private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
- public static void main(String[] args) throws AxisFault {
+ public static void main(String[] args) throws Exception {
String axisClientRepo = null;
if (args!=null && args.length>0)
@@ -66,7 +62,7 @@
new AsyncPingClient().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;
@@ -89,7 +85,7 @@
EndpointReference endpoint = serviceClient.getMyEPR(Constants.TRANSPORT_HTTP);
clientOptions.setProperty(SandeshaClientConstants.AcksTo,endpoint.getAddress());
- clientOptions.setTransportInProtocol(Constants.TRANSPORT_HTTP);
+ clientOptions.setTransportInProtocol(org.apache.axis2.Constants.TRANSPORT_HTTP);
clientOptions.setAction("urn:wsrm:Ping");
String sequenceKey = "sequence2";
@@ -109,15 +105,15 @@
if (sequenceReport!=null && sequenceReport .getCompletedMessages().size()==3)
complete = true;
else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
+
+ Thread.sleep(1000);
}
}
- serviceClient.cleanup();
+ Thread.sleep(4000);
+
+ configContext.getListenerManager().stop();
+ serviceClient.cleanup();
}
private static OMElement getPingOMBlock(String text) {
Modified: webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncEchoClient.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncEchoClient.java?view=diff&rev=482013&r1=482012&r2=482013
==============================================================================
--- webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncEchoClient.java (original)
+++ webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncEchoClient.java Sun Dec 3 18:15:38 2006
@@ -74,7 +74,7 @@
System.out.println("ERROR: Please change <SANDESHA2_HOME> to your Sandesha2 installation directory.");
return;
}
-
+
String axis2_xml = AXIS2_CLIENT_PATH + "client_axis2.xml";
ConfigurationContext configContext = ConfigurationContextFactory.createConfigurationContextFromFileSystem(AXIS2_CLIENT_PATH,axis2_xml);
@@ -114,9 +114,16 @@
Callback callback3 = new TestCallback ("Callback 3");
serviceClient.sendReceiveNonBlocking(getEchoOMBlock("echo3",sequenceKey),callback3);
- while (!callback3.isComplete()) {
- Thread.sleep(1000);
+ while (!callback1.isComplete() &&
+ !callback2.isComplete() &&
+ !callback3.isComplete()) {
+ Thread.sleep(1000);
}
+
+ Thread.sleep(6000);
+
+ configContext.getListenerManager().stop();
+ serviceClient.cleanup();
}
private static OMElement getEchoOMBlock(String text, String sequenceKey) {
Modified: webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncPingClient.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncPingClient.java?view=diff&rev=482013&r1=482012&r2=482013
==============================================================================
--- webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncPingClient.java (original)
+++ webservices/sandesha/branches/sandesha2/java/1_1/samples/src/sandesha2/samples/userguide/SyncPingClient.java Sun Dec 3 18:15:38 2006
@@ -48,14 +48,14 @@
private String toPort = "8080";
private String transportToPort = "8070";
- private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMSampleService";
+ private String toEPR = "http://" + toIP + ":" + toPort + "/axis2/services/RMSampleServic";
private String transportToEPR = "http://" + toIP + ":" + transportToPort + "/axis2/services/RMSampleService";
private static String SANDESHA2_HOME = "<SANDESHA2_HOME>"; //Change this to ur path.
private static String AXIS2_CLIENT_PATH = SANDESHA2_HOME + File.separator + "target" + File.separator +"repos" + File.separator + "client" + File.separator; //this will be available after a maven build
- public static void main(String[] args) throws AxisFault {
+ public static void main(String[] args) throws Exception {
String axisClientRepo = null;
if (args!=null && args.length>0)
@@ -65,12 +65,12 @@
AXIS2_CLIENT_PATH = axisClientRepo;
SANDESHA2_HOME = "";
}
-
+
new SyncPingClient ().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.");
@@ -106,7 +106,6 @@
serviceClient.fireAndForget(getPingOMBlock("ping2"));
clientOptions.setProperty(SandeshaClientConstants.LAST_MESSAGE, "true");
-
serviceClient.fireAndForget(getPingOMBlock("ping3"));
SequenceReport sequenceReport = null;
@@ -117,15 +116,15 @@
if (sequenceReport!=null && sequenceReport.getCompletedMessages().size()==3)
complete = true;
else {
- try {
- Thread.sleep(1000);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
+
+ Thread.sleep(1000);
}
}
- serviceClient.cleanup();
+ Thread.sleep(4000);
+
+ configContext.getListenerManager().stop();
+ serviceClient.cleanup();
}
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