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

The endpoint's afterPropertiesSet() method is invoked after error-handler configuration so that the error-handler will be configured for a ConcurrentTarget (INT-211).

Browse Source
This commit is contained in:
Mark Fisher
2008-05-21 17:05:07 +00:00
parent 8941a82ba1
commit d19f67d104
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBus.java
View File

@@ -302,7 +302,6 @@ public class MessageBus implements ChannelRegistry, EndpointRegistry, Applicatio
if (endpoint.getConcurrencyPolicy() == null && this.defaultConcurrencyPolicy != null) {
endpoint.setConcurrencyPolicy(this.defaultConcurrencyPolicy);
}
endpoint.afterPropertiesSet();
}
public MessageEndpoint unregisterEndpoint(String name) {
@@ -391,6 +390,7 @@ public class MessageBus implements ChannelRegistry, EndpointRegistry, Applicatio
targetEndpoint.setErrorHandler(new MessagePublishingErrorHandler(this.getErrorChannel()));
}
}
endpoint.afterPropertiesSet();
this.activateSubscription(channel, endpoint, subscription.getSchedule());
if (logger.isInfoEnabled()) {
logger.info("activated subscription to channel '" + channel.getName() +