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: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
