Author: chamikara
Date: Mon Oct 24 23:06:52 2005
New Revision: 328269
URL: http://svn.apache.org/viewcvs?rev=328269&view=rev
Log:
Refactored sample classes
Modified:
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/SimpleSandesha2Server.java
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncEchoClient.java
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncPingClient.java
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncEchoClient.java
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncPingClient.java
Modified:
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/SimpleSandesha2Server.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/SimpleSandesha2Server.java?rev=328269&r1=328268&r2=328269&view=diff
==============================================================================
---
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/SimpleSandesha2Server.java
(original)
+++
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/SimpleSandesha2Server.java
Mon Oct 24 23:06:52 2005
@@ -21,7 +21,7 @@
public class SimpleSandesha2Server {
- private static String SANDESHA_HOME = "E:\\sandesha\\sandesha
2\\code\\checkouts\\Aug_25_2005\\"; //Change this to ur path.
+ private static String SANDESHA_HOME = "<SANDESHA_HOME>"; //Change this
to ur path.
private static String AXIS2_SERVER_PATH = SANDESHA_HOME +
"target\\server\\"; //this will be available after a maven build
Modified:
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncEchoClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncEchoClient.java?rev=328269&r1=328268&r2=328269&view=diff
==============================================================================
---
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncEchoClient.java
(original)
+++
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncEchoClient.java
Mon Oct 24 23:06:52 2005
@@ -32,15 +32,22 @@
import org.apache.sandesha2.util.SandeshaUtil;
public class AsyncEchoClient {
- private static String sandesha1TO =
"http://localhost:8070/axis/services/RMSampleService";;
-
- private static String replyTo =
"http://localhost:9070/axis/services/RMSampleService";;
- private static String sandesha2TO =
"http://localhost:8070/axis2/services/InteropService";;
+ private String toIP = "127.0.0.1";
+
+ private String toPort = "8070";
+
+ private String ackIP = "127.0.0.1";
+
+ private String ackPort = "9070";
+
+ private String toEPR = "http://"; + toIP + ":" + toPort +
"/axis2/services/InteropService";
- private static String SANDESHA_HOME = "E:\\sandesha\\sandesha
2\\code\\checkouts\\"; //Change this to ur path.
+ private String acksToEPR = "http://"; + ackIP + ":" + ackPort +
"/axis2/services/AnonymousService/echoString";
+
+ private String SANDESHA_HOME = "<SANDESHA_HOME>"; //Change this to ur
path.
- private static String AXIS2_CLIENT_PATH = SANDESHA_HOME +
"target\\client\\"; //this will be available after a maven build
+ private String AXIS2_CLIENT_PATH = SANDESHA_HOME + "target\\client\\";
//this will be available after a maven build
public static void main(String[] args) throws AxisFault {
new AsyncEchoClient ().run();
@@ -49,8 +56,8 @@
private void run () throws AxisFault {
Call call = new Call(AXIS2_CLIENT_PATH);
call.engageModule(new QName("sandesha"));
-
call.set(Constants.AcksTo,"http://localhost:9070/axis2/services/AnonymousService/echoString";);
//Optional
- call.setTo(new EndpointReference(sandesha2TO));
+ call.set(Constants.AcksTo,acksToEPR); //Optional
+ call.setTo(new EndpointReference(toEPR));
call.set(Constants.SEQUENCE_KEY,"sequence1"); //Optional
call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
//Optional
call.setTransportInfo(org.apache.axis2.Constants.TRANSPORT_HTTP,org.apache.axis2.Constants.TRANSPORT_HTTP,true);
@@ -62,25 +69,6 @@
Callback callback3 = new TestCallback ("Callback 3");
call.invokeNonBlocking("echoString",
getEchoOMBlock("echo3"),callback3);
- }
-
- public void testEcho () throws AxisFault {
-
- Call call = new Call(AXIS2_CLIENT_PATH);
- call.engageModule(new QName("sandesha"));
-
-
call.set(Constants.AcksTo,"http://localhost:9070/axis2/services/AnonymousService/echoString";);
//Optional
- call.setTo(new EndpointReference(sandesha2TO));
- call.set(Constants.SEQUENCE_KEY,"sequence1"); //Optional
- call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
//Optional
-
call.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");
- Callback callback3 = new TestCallback ("Callback 3");
- call.invokeNonBlocking("echoString",
getEchoOMBlock("echo3"),callback3);
}
private static OMElement getEchoOMBlock(String text) {
Modified:
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncPingClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncPingClient.java?rev=328269&r1=328268&r2=328269&view=diff
==============================================================================
---
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncPingClient.java
(original)
+++
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/AsyncPingClient.java
Mon Oct 24 23:06:52 2005
@@ -30,15 +30,21 @@
public class AsyncPingClient {
- private static String sandesha1TO =
"http://localhost:8070/axis/services/RMSampleService";;
-
- private static String replyTo =
"http://localhost:9070/axis/services/RMSampleService";;
+ private String toIP = "127.0.0.1";
+
+ private String toPort = "8070";
+
+ private String ackIP = "127.0.0.1";
- private static String sandesha2TO =
"http://localhost:8070/axis2/services/InteropService";;
+ private String ackPort = "9070";
- private static String SANDESHA_HOME = "E:\\sandesha\\sandesha
2\\code\\checkouts\\"; //Change this to ur path.
+ private String toEPR = "http://"; + toIP + ":" + toPort +
"/axis2/services/InteropService";
+
+ private String acksToEPR = "http://"; + ackIP + ":" + ackPort +
"/axis2/services/AnonymousService/echoString";
+
+ private String SANDESHA_HOME = "<SANDESHA_HOME>"; //Change this to ur
path.
- private static String AXIS2_CLIENT_PATH = SANDESHA_HOME +
"target\\client\\"; //this will be available after a maven build
+ private String AXIS2_CLIENT_PATH = SANDESHA_HOME + "target\\client\\";
//this will be available after a maven build
public static void main(String[] args) throws AxisFault {
new AsyncPingClient().run();
@@ -46,9 +52,9 @@
public void run () throws AxisFault {
MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH);
-
sender.set(Constants.AcksTo,"http://localhost:9070/axis2/services/AnonymousService/ping";);
+ sender.set(Constants.AcksTo,acksToEPR);
sender.engageModule(new QName ("sandesha"));
- sender.setTo(new EndpointReference(sandesha2TO));
+ sender.setTo(new EndpointReference(toEPR));
sender.set(Constants.SEQUENCE_KEY,"sequence1");
sender.send("ping",getPingOMBlock("ping1"));
sender.send("ping",getPingOMBlock("ping2"));
Modified:
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncEchoClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncEchoClient.java?rev=328269&r1=328268&r2=328269&view=diff
==============================================================================
---
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncEchoClient.java
(original)
+++
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncEchoClient.java
Mon Oct 24 23:06:52 2005
@@ -33,15 +33,15 @@
public class SyncEchoClient {
- private static String sandesha1TO =
"http://localhost:8070/axis/services/RMSampleService";;
-
- private static String replyTo =
"http://localhost:9070/axis/services/RMSampleService";;
+ private String toIP = "127.0.0.1";
+
+ private String toPort = "8070";
- private static String sandesha2TO =
"http://localhost:8070/axis2/services/InteropService";;
+ private String toEPR = "http://"; + toIP + ":" + toPort +
"/axis2/services/InteropService";
- private static String SANDESHA_HOME = "E:\\sandesha\\sandesha
2\\code\\checkouts\\"; //Change this to ur path.
+ private String SANDESHA_HOME = "<SANDESHA_HOME>"; //Change this to ur
path.
- private static String AXIS2_CLIENT_PATH = SANDESHA_HOME +
"target\\client\\"; //this will be available after a maven build
+ private String AXIS2_CLIENT_PATH = SANDESHA_HOME + "target\\client\\";
//this will be available after a maven build
public static void main(String[] args) throws AxisFault {
new SyncEchoClient().run();
@@ -50,26 +50,7 @@
private void run () throws AxisFault {
Call call = new Call(AXIS2_CLIENT_PATH);
call.engageModule(new QName("sandesha"));
- call.setTo(new EndpointReference(sandesha2TO));
- call.set(Constants.SEQUENCE_KEY,"sequence1"); //Optional
- call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
//Optional
-
call.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");
- Callback callback3 = new TestCallback ("Callback 3");
- call.invokeNonBlocking("echoString",
getEchoOMBlock("echo3"),callback3);
- }
-
- public void testEcho () throws AxisFault {
-
- Call call = new Call(AXIS2_CLIENT_PATH);
- call.engageModule(new QName("sandesha"));
-
-
call.set(Constants.AcksTo,"http://localhost:9070/axis2/services/AnonymousService/echoString";);
//Optional
- call.setTo(new EndpointReference(sandesha2TO));
+ call.setTo(new EndpointReference(toEPR));
call.set(Constants.SEQUENCE_KEY,"sequence1"); //Optional
call.set(Constants.OFFERED_SEQUENCE_ID,SandeshaUtil.getUUID());
//Optional
call.setTransportInfo(org.apache.axis2.Constants.TRANSPORT_HTTP,org.apache.axis2.Constants.TRANSPORT_HTTP,true);
Modified:
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncPingClient.java
URL:
http://svn.apache.org/viewcvs/webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncPingClient.java?rev=328269&r1=328268&r2=328269&view=diff
==============================================================================
---
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncPingClient.java
(original)
+++
webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2/clients/SyncPingClient.java
Mon Oct 24 23:06:52 2005
@@ -29,15 +29,15 @@
public class SyncPingClient {
- private static String sandesha1TO =
"http://localhost:8070/axis/services/RMSampleService";;
-
- private static String replyTo =
"http://localhost:9070/axis/services/RMSampleService";;
+ private String toIP = "127.0.0.1";
+
+ private String toPort = "8070";
- private static String sandesha2TO =
"http://localhost:8070/axis2/services/InteropService";;
+ private String toEPR = "http://"; + toIP + ":" + toPort +
"/axis2/services/InteropService";
- private static String SANDESHA_HOME = "E:\\sandesha\\sandesha
2\\code\\checkouts\\"; //Change this to ur path.
+ private String SANDESHA_HOME = "<SANDESHA_HOME>"; //Change this to ur
path.
- private static String AXIS2_CLIENT_PATH = SANDESHA_HOME +
"target\\client\\"; //this will be available after a maven build
+ private String AXIS2_CLIENT_PATH = SANDESHA_HOME + "target\\client\\";
//this will be available after a maven build
public static void main(String[] args) throws AxisFault {
new SyncPingClient ().run();
@@ -46,7 +46,7 @@
public void run () throws AxisFault {
MessageSender sender = new MessageSender (AXIS2_CLIENT_PATH);
sender.engageModule(new QName ("sandesha"));
- sender.setTo(new EndpointReference(sandesha2TO));
+ sender.setTo(new EndpointReference(toEPR));
sender.set(Constants.SEQUENCE_KEY,"sequence1");
sender.send("ping",getPingOMBlock("ping1"));
sender.send("ping",getPingOMBlock("ping2"));
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
