Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1667: change < to <= for message group reaping

Browse Source
This commit is contained in:
Dave Syer
2010-12-06 17:52:04 +00:00
parent b4d22ac021
commit 15bdb84f0b
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java
View File

@@ -60,7 +60,7 @@ public abstract class AbstractMessageGroupStore implements MessageGroupStore, It
int count = 0;
long threshold = System.currentTimeMillis() - timeout;
for (MessageGroup group : this) {
if (group.getTimestamp() < threshold) {
if (group.getTimestamp() <= threshold) {
count++;
expire(group);
}