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 2005/10/25 08:07:18 UTC
svn commit: r328269 - in
/webservices/sandesha/trunk/samples/interop/src/org/apache/sandesha2:
SimpleSandesha2Server.java clients/AsyncEchoClient.java
clients/AsyncPingClient.java clients/SyncEchoClient.java
clients/SyncPingClient.java
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: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org