如何在使用@bean配置时到达消息endpoint

Question

当我使用spring文档中描述的配置时：

@Configuration
@EnableIntegration
public class MyFlowConfiguration {

    @Bean
    @InboundChannelAdapter(value = "inputChannel", poller = @Poller(fixedDelay = "1000"))
    public MessageSource<String> consoleSource() {
        return CharacterStreamReadingMessageSource.stdin();
    }

    @Bean
    @Transformer(inputChannel = "inputChannel", outputChannel = "httpChannel")
    public ObjectToMapTransformer toMapTransformer() {
        return new ObjectToMapTransformer();
    }

    @Bean
    @ServiceActivator(inputChannel = "httpChannel")
    public MessageHandler httpHandler() {
        HttpRequestExecutingMessageHandler handler = new HttpRequestExecutingMessageHandler("http://foo/service");
        handler.setExpectedResponseType(String.class);
        handler.setOutputChannelName("outputChannel");
        return handler;
    }

    @Bean
    @ServiceActivator(inputChannel = "outputChannel")
    public LoggingHandler loggingHandler() {
        return new LoggingHandler("info");
    }

}

Answer 1

如果我理解正确的话，您希望将其中一些endpoint注入到您的服务中。不确定“Why？”，但可以这样做（例如，对于HttpHandler)：

@Autowire
@Qualifier("myFlowConfiguration.httpHandler.serviceActivator")
private AbstractEndpoint httpEndpoint;

根据上述规则：

>

MyFlowConfiguration-类的bean名称，该类包含具有@ServiceActivator的方法。在您的例子中，它是您的@configuration

HttpHandler@ServiceActivator的方法名

ServiceActivator-@ServiceActivator的非独立名称。

清楚了吗？

/* using fully qualified class names as default bean names */
 private BeanNameGenerator importBeanNameGenerator = new   AnnotationBeanNameGenerator() {
    @Override
    protected String buildDefaultBeanName(BeanDefinition definition) {
        return definition.getBeanClassName();
    }
};

因此，如果我们要从那些未命名的类中引用endpoint，我们必须记住这一点。

当然，为了简化您的生活，您只需在myflowconfiguration中添加一个名称即可：

@Configuration("myFlowConfiguration")
@EnableIntegration
public class MyFlowConfiguration {