From 3a70b1b3f4c56c1082a4af44af47193905356c9a Mon Sep 17 00:00:00 2001
From: Dave Syer <dsyer@vmware.com>
Date: Thu, 23 Sep 2010 18:32:54 +0200
Subject: [PATCH] INT-1366: Prevent possible race

---
 .../integration/store/MessageGroupQueue.java                | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java b/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java
index 53a61dc72e..30f08365e5 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/store/MessageGroupQueue.java
@@ -72,10 +72,10 @@ public class MessageGroupQueue extends AbstractQueue<Message<?>> implements Bloc
 	}
 
 	public boolean offer(Message<?> e) {
-		if (messageGroupStore.getMessageGroup(groupId).size() >= capacity) {
-			return false;
-		}
 		synchronized (storeLock) {
+			if (messageGroupStore.getMessageGroup(groupId).size() >= capacity) {
+				return false;
+			}
 			messageGroupStore.addMessageToGroup(groupId, e);
 		}
 		synchronized (readLock) {