Advertisement

升级 Spring Cloud Stream 至3.1及以上版本,并解决函数式定义 binding 无法生效的问题

阅读量:

一、背景

项目采用了 upgraded Spring Cloud 架构,并相应地将 Spring Cloud Stream 更新至 3.2.x 版本。然而在这一过程中发现之前使用的某些注解已不再适用,请注意以下主要的变化:其中涉及的主要注解包括 @EnableBinding 和 @StreamListener 等。

在这里插入图片描述

于是在定义新的 binding 时使用函数式,但是却无法生效。

二、问题重现

新建一个 biding ,按照官网的教程,写好配置文件与代码

复制代码
    @Component
    public class MyOrderListener {
    
    
    @Bean
    public Consumer<String> orderListener() {
        return msg -> {
            // 收到消息
        };
    }
    
    }
复制代码
    spring:
      cloud:
    function:
      # 只

全部评论 (0)

还没有任何评论哟~