Spring 云流中的 PollableChannel

Question

如何使用 Spring Cloud Stream 中的 PollableChannel 从输入接收流？谢谢

Answer 1

您甚至不需要 @StreamListener 注释来从 Binder 接收数据。只需为您的微服务提供 @EnableBinding(Processor.class) 并注入一个像这样的 bean：

@Autowired
@Qualifier(Processor.INPUT)
private MessageChannel inputChannel;

并手动订阅。

或者您可以使用任何 Spring 集成方法来订阅 MessageChannel，例如：

@Bean
IntegrationFlow myProcess() {
   return IntegrationFlows.from(Processor.INPUT)
          ...
          .get();

}

@StreamListener完全区别于绑定

PollableChannel in Spring Cloud Stream