|
From: <cy...@us...> - 2003-05-25 04:12:02
|
Update of /cvsroot/ebxmlms/ebxmlms/src/hk/hku/cecid/phoenix/message/handler
In directory sc8-pr-cvs1:/tmp/cvs-serv12549
Modified Files:
Tag: b0931
DeliveryRecord.java
Log Message:
Bug fix: lastDelivered should be reset to -1 if the last message is really
delivered and there is no more undelivered message left. Thus, this
DeliveryRecord can be reused to received MessageOrder for the same
conversationId.
Index: DeliveryRecord.java
===================================================================
RCS file: /cvsroot/ebxmlms/ebxmlms/src/hk/hku/cecid/phoenix/message/handler/DeliveryRecord.java,v
retrieving revision 1.6.2.2
retrieving revision 1.6.2.3
diff -C2 -d -r1.6.2.2 -r1.6.2.3
*** DeliveryRecord.java 18 May 2003 02:15:02 -0000 1.6.2.2
--- DeliveryRecord.java 25 May 2003 04:11:58 -0000 1.6.2.3
***************
*** 110,113 ****
--- 110,114 ----
private int lastDelivered;
+ private int prevLastDelivered;
private Set undeliveredSet;
***************
*** 115,118 ****
--- 116,120 ----
undeliveredSet = new TreeSet();
lastDelivered = -1;
+ prevLastDelivered = 0;
}
***************
*** 124,132 ****
lastDelivered++;
undeliveredSet.remove(new Integer(lastDelivered));
}
void decLastDelivered() {
! undeliveredSet.add(new Integer(lastDelivered));
! lastDelivered--;
}
--- 126,145 ----
lastDelivered++;
undeliveredSet.remove(new Integer(lastDelivered));
+ if (undeliveredSet.isEmpty()) {
+ prevLastDelivered = lastDelivered;
+ lastDelivered = -1;
+ }
}
void decLastDelivered() {
! if (lastDelivered != -1) {
! undeliveredSet.add(new Integer(lastDelivered));
! lastDelivered--;
! }
! else {
! undeliveredSet.add(new Integer(prevLastDelivered));
! lastDelivered = prevLastDelivered - 1;
! prevLastDelivered = 0;
! }
}
|