From 15bdb84f0bc365aa26ec06bd53b596f10faa75a7 Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@vmware.com>
Date: Mon, 6 Dec 2010 17:52:04 +0000
Subject: [PATCH] INT-1667: change < to <= for message group reaping

---
 .../integration/store/AbstractMessageGroupStore.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java b/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java
index 5cf0bac475..1efc03d8e2 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/store/AbstractMessageGroupStore.java
@@ -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);
 			}