springboot+RabbitMQ 问题 RabbitListener 动态队列名称:Attribute value must be constant

因为多机环境fanout广播模式,每台机器需要使用自己的队列接受消息
所以尝试使用以下的方案

    private static final String QUEUE_NAME="foo."+IPUtils.getLocalhostIp();
    @RabbitListener(queues = QUEUE_NAME)
    public void process(String command){
        ...
    }

but...果断报错:Attribute value must be constant

解决方案----Spring SPEL表达式闪亮登场(网上都是什么乱七八糟复杂又不好用的)

    private static final String QUEUE_NAME="foo."+IPUtils.getLocalhostIp();

    @Bean
    public Queue queue(){
        return new Queue(QUEUE_NAME,true);
    }
    @RabbitListener(queues = "#{queue.name}")
    public void process(String command){
        ...
    }

以上

©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容