Spring Cloud Dataflow отправляет буферизованные сообщения на выходной канал

Question

У меня есть фильтр, который буферизует отклоненные сообщения. Я хотел бы направить эти буферизованные сообщения в выходной канал, как только мой предикат выполняется:

public class MyFilter implements MessageSelector { 

    private Buffer buff; 

    ... 

    @Override 
    public boolean accept(final Message<?> message) { 
     if (isAcceptable(message))) { 
      for (final Message<?> msg : buff.getBuffered()) { 
       // accept these as well 
      } 
      return true; 
     } else { 
      buff.put(message); 
      return false; 
     } 
    } 
} 

Как я могу принять буферизованные сообщения? Есть ли лучший подход?

Answer 1

Я бы предположил, что aggregator с обычным ReleaseStrategy будет хорошим подходом. Когда стратегия выпуска освобождает группу, если выходной процессор (@Aggregator метод при настройке таким образом) возвращает коллекцию Message<?>, они будут выпущены как отдельные сообщения.

При использовании конфигурации Java вам может быть проще использовать функцию Java DSL .aggregate(...), чем создание @Bean s.

В настоящее время pull request для стартера приложения агрегатора.