diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractOutboundChannelAdapterParser.java b/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractOutboundChannelAdapterParser.java index 1e49819765..97e279fc3e 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractOutboundChannelAdapterParser.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/config/AbstractOutboundChannelAdapterParser.java @@ -40,9 +40,7 @@ public abstract class AbstractOutboundChannelAdapterParser extends AbstractChann Element pollerElement = DomUtils.getChildElementByTagName(element, "poller"); BeanDefinitionBuilder adapterBuilder = null; adapterBuilder = BeanDefinitionBuilder.genericBeanDefinition(OutboundChannelAdapter.class); - AbstractBeanDefinition consumerBeanDefinition = this.parseConsumer(element, parserContext); - String consumerBeanName = BeanDefinitionReaderUtils.registerWithGeneratedName( - consumerBeanDefinition, parserContext.getRegistry()); + String consumerBeanName = this.parseAndRegisterConsumer(element, parserContext); adapterBuilder.addConstructorArgReference(consumerBeanName); if (pollerElement != null) { if (!StringUtils.hasText(channelName)) {