SpringBoot RabbitMQ 动态添加Queue和Listener

之前项目中涉及了动态配置Queue name的需求，但是解决了一直没有记录，今天看到了顺便记录下

首先声明一个Queue的bean，这里面你就可以拼接你想要的queue的name

1.  
   //import org.springframework.amqp.core.Queue;
2.  
   @Bean
3.  
   public Queue DynamicQueue() {
4.  
   return new Queue("queue_str" someFunction.getSomeParm(), true);
5.  
   }

 这里True的意思是一个持久的Queue

 然后就是写Listener了，注册监听该Queue

1.  
   //import org.springframework.amqp.rabbit.annotation.RabbitListener
2.  
   //import org.springframework.amqp.core.Message;
3.  
    
4.  
   @RabbitListener(queues = "#{DynamicQueue.name}")
5.  
   public void getMsg(Message msg) {
6.  
   //...
7.  
   }

这篇好文章是转载于：学新通技术网