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

Question

我正在尝试使用 Spring 云流源来输出反应性通量（来自 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 来跟踪此要求。

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

Spring Cloud Stream Source returning a reactive Flux<>?

spring-cloud-stream