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

added applySequence and ignoreSendFailures properties to the RouterFactoryBean

Browse Source
This commit is contained in:
Mark Fisher
2010-03-12 02:10:07 +00:00
parent ab4e689bc9
commit 76e8876afe
1 changed files with 19 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,5 +1,5 @@
/*
* Copyright 2002-2009 the original author or authors.
* Copyright 2002-2010 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -44,6 +44,10 @@ public class RouterFactoryBean extends AbstractMessageHandlerFactoryBean {
private volatile Boolean ignoreChannelNameResolutionFailures;
private volatile Boolean applySequence;
private volatile Boolean ignoreSendFailures;
public void setChannelResolver(ChannelResolver channelResolver) {
this.channelResolver = channelResolver;
@@ -65,6 +69,14 @@ public class RouterFactoryBean extends AbstractMessageHandlerFactoryBean {
this.ignoreChannelNameResolutionFailures = ignoreChannelNameResolutionFailures;
}
public void setApplySequence(Boolean applySequence) {
this.applySequence = applySequence;
}
public void setIgnoreSendFailures(Boolean ignoreSendFailures) {
this.ignoreSendFailures = ignoreSendFailures;
}
@Override
MessageHandler createMethodInvokingHandler(Object targetObject, String targetMethodName) {
Assert.notNull(targetObject, "target object must not be null");
@@ -106,6 +118,12 @@ public class RouterFactoryBean extends AbstractMessageHandlerFactoryBean {
+ AbstractChannelNameResolvingMessageRouter.class.getName());
((AbstractChannelNameResolvingMessageRouter) router).setIgnoreChannelNameResolutionFailures(ignoreChannelNameResolutionFailures);
}
if (this.applySequence != null) {
router.setApplySequence(this.applySequence);
}
if (this.ignoreSendFailures != null) {
router.setIgnoreSendFailures(this.ignoreSendFailures);
}
if (this.resolutionRequired != null) {
router.setResolutionRequired(this.resolutionRequired);
}