Spring Cloud Stream Source返回反应流量<>？

我想有一个春天的云溪源输出的活性焊剂（从工程反应堆）。在我的pom.xml，spring-cloud-stream-reactive和reactor-core导入为依赖关系。我已经宣布了下面的代码：Spring Cloud Stream Source返回反应流量<>？

@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做类似的事情？

在此先感谢。

来源

2016-11-29 ctranxuan

@StreamListener是通过其性质旨在被用于接收器和处理器。

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

来源

2016-11-29 14:40:16

你的意思的答案处理器和汇:) 谢谢！ – ctranxuan

你觉得不使用'@InboundChannelAdapter（通道= Source.OUTPUT，轮询= @Poller（固定利率=“10”））'这是使用反应式库建立一个源是否可行？我的意思是说，可能需要比添加一些注释更多的编码工作。 – ctranxuan

'@ InboundChannelAdapter'直接写入频道 - 如果你愿意，你可以使用它，但它是一个独特的实现。 –

Spring Cloud Stream Source返回反应流量<>？

回答

相关问题