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

INT-1940 changed locks map to have correlationId -> new Object()

Browse Source
This commit is contained in:
Oleg Zhurakousky
2011-06-23 16:13:03 -04:00
parent 9299c36953
commit d5bb9a8297
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/aggregator/CorrelatingMessageHandler.java
View File

@@ -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);
}
}