From 8de53ccee915b8dc3ead469b0347ddada6887248 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Mon, 29 Apr 2019 14:15:14 -0400 Subject: [PATCH] Polishing - PR comment --- .../integration/config/ConsumerEndpointFactoryBean.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/spring-integration-core/src/main/java/org/springframework/integration/config/ConsumerEndpointFactoryBean.java b/spring-integration-core/src/main/java/org/springframework/integration/config/ConsumerEndpointFactoryBean.java index d96665fbaa..7a210359b7 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/config/ConsumerEndpointFactoryBean.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/config/ConsumerEndpointFactoryBean.java @@ -44,11 +44,11 @@ import org.springframework.integration.endpoint.ReactiveStreamsConsumer; import org.springframework.integration.handler.AbstractReplyProducingMessageHandler; import org.springframework.integration.handler.advice.HandleMessageAdvice; import org.springframework.integration.scheduling.PollerMetadata; +import org.springframework.integration.support.channel.ChannelResolverUtils; import org.springframework.messaging.MessageChannel; import org.springframework.messaging.MessageHandler; import org.springframework.messaging.PollableChannel; import org.springframework.messaging.SubscribableChannel; -import org.springframework.messaging.core.BeanFactoryMessageChannelDestinationResolver; import org.springframework.messaging.core.DestinationResolver; import org.springframework.scheduling.TaskScheduler; import org.springframework.util.Assert; @@ -237,7 +237,7 @@ public class ConsumerEndpointFactoryBean } } if (this.channelResolver == null) { - this.channelResolver = new BeanFactoryMessageChannelDestinationResolver(this.beanFactory); + this.channelResolver = ChannelResolverUtils.getChannelResolver(this.beanFactory); } initializeEndpoint(); }