Spring Cloud Stream Source 返回响应式 Flux<>？

Question

我正在尝试使用 Spring Cloud Stream Source 来输出反应通量（来自 Project Reactor）。 在我的 pom.xml 中，spring-cloud-stream-reactive 和 reactor-core 被导入为依赖项。 我已经声明了以下代码：

@SpringBootApplication
@EnableBinding(Source.class)
public class SensorDataSourceApplication {

   @StreamListener
   @Output(Source.OUTPUT)
   public Flux<String> emitPolling() {
     return Flux.intervalMillis(5000)
                .log()
                .map(l -> "Hello World!!")
                .log()
                ;
   }
}

但我的处理器或接收器中没有任何东西。我发现的所有示例都与Processor 有关。所以，我想知道是否可以为Source 做类似的事情？

提前致谢。

Answer 1

@StreamListener 本质上旨在用于接收器和处理器。

我已添加 https://github.com/spring-cloud/spring-cloud-stream/issues/722 来跟踪此要求。