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

INT-598

Browse Source
This commit is contained in:
Mark Fisher
2009-03-12 14:02:49 +00:00
parent 34a977a3a0
commit d3a671cd68
3 changed files with 124 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
org.springframework.integration/src/main/java/org/springframework/integration/config/RouterFactoryBean.java
View File

@@ -37,10 +37,11 @@ public class RouterFactoryBean extends AbstractMessageHandlerFactoryBean {
private volatile MessageChannel defaultOutputChannel;
private volatile boolean resolutionRequired;
private volatile Boolean resolutionRequired;
private volatile Boolean ignoreChannelNameResolutionFailures;
public void setChannelResolver(ChannelResolver channelResolver) {
this.channelResolver = channelResolver;
}
@@ -48,12 +49,12 @@ public class RouterFactoryBean extends AbstractMessageHandlerFactoryBean {
public void setDefaultOutputChannel(MessageChannel defaultOutputChannel) {
this.defaultOutputChannel = defaultOutputChannel;
}
public void setResolutionRequired(boolean resolutionRequired){
public void setResolutionRequired(Boolean resolutionRequired) {
this.resolutionRequired = resolutionRequired;
}
public void setIgnoreChannelNameResolutionFailures(boolean ignoreChannelNameResolutionFailures){
public void setIgnoreChannelNameResolutionFailures(Boolean ignoreChannelNameResolutionFailures) {
this.ignoreChannelNameResolutionFailures = ignoreChannelNameResolutionFailures;
}
@@ -64,12 +65,15 @@ public class RouterFactoryBean extends AbstractMessageHandlerFactoryBean {
if (this.defaultOutputChannel != null) {
router.setDefaultOutputChannel(this.defaultOutputChannel);
}
if(ignoreChannelNameResolutionFailures != null ){
if (this.ignoreChannelNameResolutionFailures != null) {
Assert.isTrue(router instanceof AbstractChannelNameResolvingMessageRouter,
"Ignore channel name resolution failures can only set on rotuers extending " + AbstractChannelNameResolvingMessageRouter.class.getName());
((AbstractChannelNameResolvingMessageRouter)router).setIgnoreChannelNameResolutionFailures(ignoreChannelNameResolutionFailures);
"The 'ignoreChannelNameResolutionFailures' property can only be set on routers that extend "
+ AbstractChannelNameResolvingMessageRouter.class.getName());
((AbstractChannelNameResolvingMessageRouter) router).setIgnoreChannelNameResolutionFailures(ignoreChannelNameResolutionFailures);
}
if (this.resolutionRequired != null) {
router.setResolutionRequired(this.resolutionRequired);
}
router.setResolutionRequired(resolutionRequired);
return router;
}