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

INT-2347 Update Channel Mappings Atomically

Browse Source 
Ensure consistent state if channel map is replaced
dynamically.
This commit is contained in:
Gary Russell
2012-01-03 10:50:54 -05:00
committed by Mark Fisher
parent f3155f86fa
commit 5750ca5ff5
1 changed files with 10 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
spring-integration-core/src/main/java/org/springframework/integration/router/AbstractMappingMessageRouter.java
View File

@@ -42,11 +42,12 @@ import org.springframework.util.StringUtils;
* @author Mark Fisher
* @author Oleg Zhurakousky
* @author Gunnar Hillert
* @author Gary Russell
* @since 2.1
*/
public abstract class AbstractMappingMessageRouter extends AbstractMessageRouter {
private final Map<String, String> channelMappings = new ConcurrentHashMap<String, String>();
private volatile Map<String, String> channelMappings = new ConcurrentHashMap<String, String>();
private volatile ChannelResolver channelResolver;
@@ -62,8 +63,14 @@ public abstract class AbstractMappingMessageRouter extends AbstractMessageRouter
* Channel names will be resolved by the {@link ChannelResolver}.
*/
public void setChannelMappings(Map<String, String> channelMappings) {
this.channelMappings.clear();
this.channelMappings.putAll(channelMappings);
Map<String, String> oldChannelMappings = this.channelMappings;
Map<String, String> newChannelMappings = new ConcurrentHashMap<String, String>();
newChannelMappings.putAll(channelMappings);
this.channelMappings = newChannelMappings;
if (logger.isDebugEnabled()) {
logger.debug("Channel mappings:" + oldChannelMappings
+ " replaced with:" + newChannelMappings);
}
}
/**