chamikara 2005/05/19 01:34:10
Modified: sandesha/src/org/apache/sandesha/client RMSender.java
sandesha/src/org/apache/sandesha RMStatus.java RMReport.java
Log:
RMStatus and RMReport were completed. Client can use these to get information
about the message
sequence after calling the RMInitiator.stopClient()
Revision Changes Path
1.43 +8 -0
ws-fx/sandesha/src/org/apache/sandesha/client/RMSender.java
Index: RMSender.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/client/RMSender.java,v
retrieving revision 1.42
retrieving revision 1.43
diff -u -r1.42 -r1.43
--- RMSender.java 16 May 2005 13:09:18 -0000 1.42
+++ RMSender.java 19 May 2005 08:34:09 -0000 1.43
@@ -30,6 +30,7 @@
import org.apache.sandesha.IStorageManager;
import org.apache.sandesha.RMInitiator;
import org.apache.sandesha.RMMessageContext;
+import org.apache.sandesha.RMStatus;
import org.apache.sandesha.util.PolicyLoader;
import org.apache.sandesha.util.RMMessageCreator;
import org.apache.sandesha.ws.rm.RMHeaders;
@@ -99,6 +100,13 @@
}
Thread.sleep(Constants.CLIENT_RESPONSE_CHECKING_INTERVAL);
}
+
+
+ //setting RMStatus;
+ if(responseMessageContext!=null)
+ RMStatus.incrementResponseCount();
+
+
//We need these steps to filter all addressing and rm
related headers.
Message resMsg =
responseMessageContext.getMsgContext().getRequestMessage();
RMHeaders.removeHeaders(resMsg.getSOAPEnvelope());
1.4 +17 -1 ws-fx/sandesha/src/org/apache/sandesha/RMStatus.java
Index: RMStatus.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/RMStatus.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- RMStatus.java 7 Mar 2005 05:34:34 -0000 1.3
+++ RMStatus.java 19 May 2005 08:34:10 -0000 1.4
@@ -16,13 +16,29 @@
*/
package org.apache.sandesha;
+import org.apache.sandesha.client.ClientStorageManager;
+
public class RMStatus {
+
+ private static int responseCount = 0;
+
+ public static void incrementResponseCount(){
+ responseCount++;
+ }
+
public boolean isComplete() {
+
return false;
}
public RMReport getReport() {
- return new RMReport();
+
+ RMReport report = new RMReport();
+ ClientStorageManager csm = new ClientStorageManager();
+ report.setAllAcked( csm.isAllSequenceComplete());
+ report.setNoOfReturmMessages(responseCount);
+ return report;
+
}
}
1.4 +14 -2 ws-fx/sandesha/src/org/apache/sandesha/RMReport.java
Index: RMReport.java
===================================================================
RCS file: /home/cvs/ws-fx/sandesha/src/org/apache/sandesha/RMReport.java,v
retrieving revision 1.3
retrieving revision 1.4
diff -u -r1.3 -r1.4
--- RMReport.java 7 Mar 2005 05:34:34 -0000 1.3
+++ RMReport.java 19 May 2005 08:34:10 -0000 1.4
@@ -17,12 +17,24 @@
package org.apache.sandesha;
public class RMReport {
+
+ private boolean allAcked;
+ private int returns;
+
public boolean isAllAcked() {
- return false;
+ return allAcked;
}
public int getNumberOfReturnMessages() {
- return 0;
+ return returns;
+ }
+
+ public void setAllAcked(boolean acked){
+ allAcked = acked;
+ }
+
+ public void setNoOfReturmMessages(int n){
+ returns = n;
}
}
