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

RouterEndpoint no longer uses its own messageExchangeTemplate (no longer ignores settings on parent).

Browse Source
This commit is contained in:
Mark Fisher
2008-09-08 16:50:00 +00:00
parent 3c50a23d85
commit fb2c5f3237
1 changed files with 1 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
org.springframework.integration/src/main/java/org/springframework/integration/router/RouterEndpoint.java
View File

@@ -24,7 +24,6 @@ import org.springframework.integration.channel.MessageChannel;
import org.springframework.integration.endpoint.AbstractMessageConsumingEndpoint;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.integration.message.MessageExchangeTemplate;
import org.springframework.util.Assert;
/**
@@ -38,8 +37,6 @@ public class RouterEndpoint extends AbstractMessageConsumingEndpoint {
private volatile boolean resolutionRequired;
private final MessageExchangeTemplate messageExchangeTemplate = new MessageExchangeTemplate();
public RouterEndpoint(ChannelResolver channelResolver) {
Assert.notNull(channelResolver, "ChannelResolver must not be null");
@@ -84,7 +81,7 @@ public class RouterEndpoint extends AbstractMessageConsumingEndpoint {
if (results != null) {
for (MessageChannel channel : results) {
if (channel != null) {
if (this.messageExchangeTemplate.send(message, channel)) {
if (this.getMessageExchangeTemplate().send(message, channel)) {
sent = true;
}
}