chamikara 2005/06/06 11:25:49
Modified: sandesha/src/org/apache/sandesha/storage/queue
OutgoingSequence.java
Log:
Three properties were added.
finalAckedTime - last time a ack was sent
finalMsgArrivedTime - the time final applicaion msg arrived
sendAck - a notification to say weather to send an ack
Revision Changes Path
1.10 +4 -1
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.9
retrieving revision 1.10
diff -u -r1.9 -r1.10
--- OutgoingSequence.java 22 May 2005 05:26:32 -0000 1.9
+++ OutgoingSequence.java 6 Jun 2005 18:25:49 -0000 1.10
@@ -21,6 +21,7 @@
import org.apache.commons.logging.Log;
import org.apache.sandesha.Constants;
import org.apache.sandesha.RMMessageContext;
+import org.apache.sandesha.util.PolicyLoader;
import java.util.Date;
import java.util.HashMap;
@@ -166,7 +167,9 @@
long lastSentTime = tempMsg.getLastSentTime();
Date d = new Date();
long currentTime = d.getTime();
- if (currentTime >= lastSentTime +
Constants.RETRANSMISSION_INTERVAL) {
+
+ long retransmissionInterval =
PolicyLoader.getInstance().getBaseRetransmissionInterval();
+ if (currentTime >= lastSentTime + retransmissionInterval) {
if (minMsg == null)
minMsg = tempMsg;
else {
