chamikara 2005/05/19 01:35:52
Modified: sandesha/interop/org/apache/sandesha/samples/interop
EchoClientSyncAck.java AsyncPingClient.java
SyncPingClient.java EchoClientAsyncAck.java
Log:
Modified to show the RMReport
Revision Changes Path
1.5 +15 -1
ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/EchoClientSyncAck.java
Index: EchoClientSyncAck.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/EchoClientSyncAck.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- EchoClientSyncAck.java 16 May 2005 06:08:17 -0000 1.4
+++ EchoClientSyncAck.java 19 May 2005 08:35:52 -0000 1.5
@@ -24,6 +24,8 @@
import org.apache.axis.components.uuid.UUIDGen;
import org.apache.sandesha.Constants;
import org.apache.sandesha.RMInitiator;
+import org.apache.sandesha.RMReport;
+import org.apache.sandesha.RMStatus;
import org.apache.sandesha.RMTransport;
import javax.xml.namespace.QName;
@@ -85,7 +87,19 @@
ret = (String) call.invoke(new Object[]{"Sandesha Echo 3", str});
System.out.println("The Response for Third Messsage is :" +
ret);
- RMInitiator.stopClient();
+ RMStatus status = RMInitiator.stopClient();
+
+ if(status!=null){
+ RMReport report = status.getReport();
+
+ if(report!=null){
+ System.out.println("\n***********Printing RM
Report***********");
+ System.out.println("Were all messages add - " +
report.isAllAcked());
+ System.out.println("No of response messages - " +
report.getNumberOfReturnMessages());
+
System.out.println("****************************************\n");
+ }
+ }
+
} catch (Exception e) {
e.printStackTrace();
}
1.11 +14 -1
ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/AsyncPingClient.java
Index: AsyncPingClient.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/AsyncPingClient.java,v
retrieving revision 1.10
retrieving revision 1.11
diff -u -r1.10 -r1.11
--- AsyncPingClient.java 18 May 2005 12:57:54 -0000 1.10
+++ AsyncPingClient.java 19 May 2005 08:35:52 -0000 1.11
@@ -22,6 +22,8 @@
import org.apache.axis.encoding.XMLType;
import org.apache.sandesha.Constants;
import org.apache.sandesha.RMInitiator;
+import org.apache.sandesha.RMReport;
+import org.apache.sandesha.RMStatus;
import org.apache.sandesha.RMTransport;
import javax.xml.namespace.QName;
@@ -69,7 +71,18 @@
call.setProperty(Constants.ClientProperties.LAST_MESSAGE, new
Boolean(true));
call.invoke(new Object[]{"Ping Message Number Three"});
- RMInitiator.stopClient();
+ RMStatus status = RMInitiator.stopClient();
+
+ if(status!=null){
+ RMReport report = status.getReport();
+
+ if(report!=null){
+ System.out.println("\n***********Printing RM
Report***********");
+ System.out.println("Were all messages add - " +
report.isAllAcked());
+ System.out.println("No of response messages - " +
report.getNumberOfReturnMessages());
+
System.out.println("****************************************\n");
+ }
+ }
} catch (Exception e) {
//System.err.println(e.toString());
1.10 +15 -1
ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/SyncPingClient.java
Index: SyncPingClient.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/SyncPingClient.java,v
retrieving revision 1.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- SyncPingClient.java 13 May 2005 11:54:01 -0000 1.9
+++ SyncPingClient.java 19 May 2005 08:35:52 -0000 1.10
@@ -22,7 +22,10 @@
import org.apache.axis.encoding.XMLType;
import org.apache.sandesha.Constants;
import org.apache.sandesha.RMInitiator;
+import org.apache.sandesha.RMReport;
+import org.apache.sandesha.RMStatus;
import org.apache.sandesha.RMTransport;
+import org.apache.sandesha.client.RMSender;
import javax.xml.namespace.QName;
import javax.xml.rpc.ParameterMode;
@@ -73,8 +76,19 @@
call.setProperty(Constants.ClientProperties.LAST_MESSAGE, new
Boolean(true));
call.invoke(new Object[]{"Ping Message Number Three"});
- RMInitiator.stopClient();
+ RMStatus status = RMInitiator.stopClient();
+ if(status!=null){
+ RMReport report = status.getReport();
+
+ if(report!=null){
+ System.out.println("\n***********Printing RM
Report***********");
+ System.out.println("Were all messages add - " +
report.isAllAcked());
+ System.out.println("No of response messages - " +
report.getNumberOfReturnMessages());
+
System.out.println("****************************************\n");
+ }
+ }
+
} catch (Exception e) {
//System.err.println(e.toString());
e.printStackTrace();
1.5 +15 -1
ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/EchoClientAsyncAck.java
Index: EchoClientAsyncAck.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/interop/org/apache/sandesha/samples/interop/EchoClientAsyncAck.java,v
retrieving revision 1.4
retrieving revision 1.5
diff -u -r1.4 -r1.5
--- EchoClientAsyncAck.java 16 May 2005 06:08:17 -0000 1.4
+++ EchoClientAsyncAck.java 19 May 2005 08:35:52 -0000 1.5
@@ -24,6 +24,8 @@
import org.apache.axis.components.uuid.UUIDGen;
import org.apache.sandesha.Constants;
import org.apache.sandesha.RMInitiator;
+import org.apache.sandesha.RMReport;
+import org.apache.sandesha.RMStatus;
import org.apache.sandesha.RMTransport;
import javax.xml.namespace.QName;
@@ -82,7 +84,19 @@
ret = (String) call.invoke(new Object[]{"Sandesha Echo 3", str});
System.out.println("The Response for Third Messsage is :" +
ret);
- RMInitiator.stopClient();
+ RMStatus status = RMInitiator.stopClient();
+
+ if(status!=null){
+ RMReport report = status.getReport();
+
+ if(report!=null){
+ System.out.println("\n***********Printing RM
Report***********");
+ System.out.println("Were all messages add - " +
report.isAllAcked());
+ System.out.println("No of response messages - " +
report.getNumberOfReturnMessages());
+
System.out.println("****************************************\n");
+ }
+ }
+
} catch (Exception e) {
e.printStackTrace();
}
