From d5bb9a8297fb95e95e5aaf9884b2f9a6caef7b44 Mon Sep 17 00:00:00 2001
From: Oleg Zhurakousky <ozhurakousky@vmware.com>
Date: Thu, 23 Jun 2011 16:13:03 -0400
Subject: [PATCH] INT-1940 changed locks map to have correlationId -> new
 Object()

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

diff --git a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java
index 25c3aa73dc..37f2627c8f 100644
--- a/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java
+++ b/spring-integration-core/src/main/java/org/springframework/integration/aggregator/CorrelatingMessageHandler.java
@@ -247,7 +247,7 @@ public class CorrelatingMessageHandler extends AbstractMessageHandler implements
 
 	private Object getLock(Object correlationKey) {
 		synchronized(correlationLocksMonitor){
-			locks.putIfAbsent(correlationKey, correlationKey);
+			locks.putIfAbsent(correlationKey, new Object());
 			return locks.get(correlationKey);
 		}
 	}