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; } }