diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/ChannelAdapterParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/ChannelAdapterParser.java index 737aae1773..f6429d424a 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/ChannelAdapterParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/ChannelAdapterParser.java @@ -89,6 +89,9 @@ public class ChannelAdapterParser extends AbstractBeanDefinitionParser { String pollerBeanName = IntegrationNamespaceUtils.parsePoller(channelName, pollerElement, parserContext); adapterBuilder.addPropertyReference("source", pollerBeanName); } + else if (StringUtils.hasText(channelName)) { + adapterBuilder.addPropertyReference("source", channelName); + } else { adapterBuilder.addPropertyReference("source", this.createDirectChannel(element, parserContext));