Spring云流功能支持不起作用

Question

我试图将Spring Cloud Stream与本主题中描述的功能一起使用。但是它不起作用。

我的职能：

@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class);
    }

    @Bean
    public Consumer<String> consumer() {
        return s -> System.out.println(s);
    }
}

我推送消息。通过使用输出注释制作的生产者，发送到consumer-in-0频道：

pulic interface Source {
    @Output("source")
    MessageChannel producer();
}

source.producer().send(MessageBuilder.withPayload("Hello").build());

我的yaml通道配置：

spring:
    cloud:
        function:
            definition: consumer
        stream:
            bindings:
                source:
                    destination: consumer-in-0

如果我通过@Input配置使用消费者，一切正常。同样在rabbitmq管理器中，我看到生产者正在工作并发送消息，但消费者并不使用它们。帮帮我，请某人帮忙。

附言：我也使用Spring WebFlux

Answer 1

不能在同一应用程序中混合启用绑定和功能模型。如果将生产者和消费者放在同一个应用程序中，则可能需要使用供应商转换生产者。例如：。

@Bean
public Supplier<String> supplier() {
  return () -> MessageBuilder.withPayload("Hello").build();

}

然后

spring:
    cloud:
        function:
            definition: supplier;consumer
        stream:
            bindings:
                supplier-out-0:
                    destination: consumer-in-0