From fb2c5f323777632abf74dd2f4b4d8714712e41b6 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Mon, 8 Sep 2008 16:50:00 +0000 Subject: [PATCH] RouterEndpoint no longer uses its own messageExchangeTemplate (no longer ignores settings on parent). --- .../springframework/integration/router/RouterEndpoint.java | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/router/RouterEndpoint.java b/org.springframework.integration/src/main/java/org/springframework/integration/router/RouterEndpoint.java index 665c9a6434..4e3c8b4ab6 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/router/RouterEndpoint.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/router/RouterEndpoint.java @@ -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; } }