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

fixed atomicity

Browse Source
This commit is contained in:
Mark Fisher
2011-11-03 10:19:12 -04:00
parent 73a63f7066
commit 50cc500429
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
spring-integration-core/src/main/java/org/springframework/integration/store/SimpleMessageStore.java
View File

@@ -169,10 +169,13 @@ public class SimpleMessageStore extends AbstractMessageGroupStore implements Mes
}
private SimpleMessageGroup getMessageGroupInternal(Object groupId) {
if (!groupIdToMessageGroup.containsKey(groupId)) {
groupIdToMessageGroup.putIfAbsent(groupId, new SimpleMessageGroup(groupId));
SimpleMessageGroup group = this.groupIdToMessageGroup.get(groupId);
if (group == null) {
SimpleMessageGroup newGroup = new SimpleMessageGroup(groupId);
SimpleMessageGroup previousGroup = this.groupIdToMessageGroup.putIfAbsent(groupId, newGroup);
group = (previousGroup == null) ? newGroup : previousGroup;
}
return groupIdToMessageGroup.get(groupId);
return group;
}
}