jaliya 2005/05/21 22:26:33
Modified: sandesha/src/org/apache/sandesha/client
ClientStorageManager.java
sandesha/src/org/apache/sandesha/storage/queue
OutgoingSequence.java
Removed: sandesha/src/org/apache/sandesha RMInitiator.java
Log:
Removed RMInitiator class. This is due to the introduction of SandeshaContext
whch will handle the same funtionality as RMIntiator but provide much flexibel
usage for clients
Revision Changes Path
1.38 +0 -6
ws-fx/sandesha/src/org/apache/sandesha/client/ClientStorageManager.java
Index: ClientStorageManager.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/client/ClientStorageManager.java,v
retrieving revision 1.37
retrieving revision 1.38
diff -u -r1.37 -r1.38
--- ClientStorageManager.java 22 May 2005 04:54:20 -0000 1.37
+++ ClientStorageManager.java 22 May 2005 05:26:32 -0000 1.38
@@ -118,13 +118,7 @@
* Get a Map of messages.
*/
public Map getListOfMessageNumbers(String sequenceID) {
- System.out.println("sendAcknowledgement need to find "+sequenceID);
-
-
- // String seq = getKeyFromOutgoingSeqId(sequenceID);
- //String seq=getOutgoingSeqenceIdOfIncomingMsg()
String seq=sequenceID;
- System.out.println("sendAcknowledgement found "+seq);
Set st = accessor.getAllReceivedMsgNumsOfIncomingSeq(seq);
Iterator it = st.iterator();
//To find the largest id present
1.9 +1 -2
ws-fx/sandesha/src/org/apache/sandesha/storage/queue/OutgoingSequence.java
Index: OutgoingSequence.java
===================================================================
RCS file:
/home/cvs/ws-fx/sandesha/src/org/apache/sandesha/storage/queue/OutgoingSequence.java,v
retrieving revision 1.8
retrieving revision 1.9
diff -u -r1.8 -r1.9
--- OutgoingSequence.java 22 May 2005 04:54:20 -0000 1.8
+++ OutgoingSequence.java 22 May 2005 05:26:32 -0000 1.9
@@ -77,8 +77,7 @@
}
public void setTerminateSent(boolean terminateSent) {
- System.out.println("TERMINATING THIS SEQUENCE "+this.sequenceId);
- this.terminateSent = terminateSent;
+ this.terminateSent = terminateSent;
}
public OutgoingSequence(String sequenceId) {
