INT-1366: Prevent possible race

2010-09-23 18:32:54 +02:00
parent 54ca59a917
commit 3a70b1b3f4
1 changed files with 3 additions and 3 deletions
--- 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) {