spring-integration-dsl: Make Feed-Flow Work

Question

Я пытаюсь закодировать считыватель RSS-каналов с настроенным набором RSS-каналов. Я подумал, что хороший подход заключается в том, чтобы решить это путем кодирования прототипа-@Bean и вызвать его с каждым RSS-каналом, найденным в конфигурации.

Однако, я думаю, что я пропустил пункт здесь, когда приложение запускается, но ничего не происходит. Я имею в виду бобы созданы, как я бы ожидать, но нет никакого протоколирования происходит в этом handle() -методе:

@Component 
public class HomeServerRunner implements ApplicationRunner { 

    private static final Logger logger = LoggerFactory.getLogger(HomeServerRunner.class); 

    @Autowired 
    private Configuration configuration; 

    @Autowired 
    private FeedConfigurator feedConfigurator; 

    @Override 
    public void run(ApplicationArguments args) throws Exception { 
     List<IntegrationFlow> feedFlows = configuration.getRssFeeds() 
      .entrySet() 
      .stream() 
      .peek(entry -> System.out.println(entry.getKey())) 
      .map(entry -> feedConfigurator.feedFlow(entry.getKey(), entry.getValue())) 
      .collect(Collectors.toList()); 
     // this one appears in the log-file and looks good 
     logger.info("Flows: " + feedFlows); 
    } 

} 

@Configuration 
public class FeedConfigurator { 

    private static final Logger logger = LoggerFactory.getLogger(FeedConfigurator.class); 

    @Bean 
    @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) 
    public IntegrationFlow feedFlow(String name, FeedConfiguration configuration) { 
     return IntegrationFlows 
       .from(Feed 
         .inboundAdapter(configuration.getSource(), getElementName(name, "adapter")) 
         .feedFetcher(new HttpClientFeedFetcher()), 
         spec -> spec.poller(Pollers.fixedRate(configuration.getInterval()))) 
       .channel(MessageChannels.direct(getElementName(name, "in"))) 
       .enrichHeaders(spec -> spec.header("feedSource", configuration)) 
       .channel(getElementName(name, "handle")) 
     // 
     // it would be nice if the following would show something: 
     // 
       .handle(m -> logger.debug("Payload: " + m.getPayload())) 
       .get(); 
    } 

    private String getElementName(String name, String postfix) { 
     name = "feedChannel" + StringUtils.capitalize(name); 
     if (!StringUtils.isEmpty(postfix)) { 
      name += "." + postfix; 
     } 
     return name; 
    } 

} 

Что здесь не хватает? Кажется, мне нужно как-то «запустить» потоки.

Answer 1

Простейшие компоненты должны быть «использованы» где-то - если у вас нет ссылки на него нигде, экземпляр не будет создан.

Кроме того, вы не можете поместить IntegrationFlow@Bean в эту область действия - он создает кучу фасованных компонентов внутри, которые не будут в этой области.

См. Ответ to this question и its follow-up за один метод, который вы можете использовать для создания нескольких адаптеров с различными свойствами.

В качестве альтернативы, предстоящий 1.2 version of the DSL имеет механизм регистрации потоков динамически.