RabbitListener注释队列名称（按配置属性）

Question

我已经通过应用程序配置了我的兔子属性。yaml和spring配置属性。因此，在配置交换、队列和绑定时，可以使用属性的getter

@Bean Binding binding(Queue queue, TopicExchange exchange) {
    return BindingBuilder.bind(queue).to(exchange).with(properties.getQueue());
}

@Bean Queue queue() {
    return new Queue(properties.getQueue(), true);
}

@Bean TopicExchange exchange() {
    return new TopicExchange(properties.getExchange());
}

然而，当我配置@RabbitListener从队列登录消息时，我必须使用完整的属性名称，如

 @RabbitListener(queues = "${some.long.path.to.the.queue.name}") 
 public void onMessage(
            final Message message, final Channel channel) throws Exception {
       log.info("receiving message: {}#{}", message, channel);
    }

我希望避免这种容易出错的硬编码字符串，并参考configurationProperties bean，如：

@RabbitListener(queues = "${properties.getQueue()}") 

我曾经遇到过一个与@EventListener类似的问题，在这里使用bean引用“@bean.method（）”很有帮助，但它在这里不起作用，bean表达式只是被解释为队列名称，这会失败，因为队列名称为“@bean….”不存在。

是否可以将ConfigurationProperty bean用于RabbitListener队列配置？

Answer 1

@RabbitListener(queues = "#{myQueue.name}") 

Answer 2

通过采纳大卫·迪尔（DavidDiehl）的建议，使用bean和SpEL，我终于能够完成我们都想要做的事情；但是，请改用MyRabbitProperties本身。我删除了config类中的@EnableConfigurationProperties（MyRabbitProperties.class），并以标准方式注册了bean：

@Configuration
//@EnableConfigurationProperties(RabbitProperties.class)
@EnableRabbit
public class RabbitConfig {
  //private final MyRabbitProperties myRabbitProperties;

  //@Autowired
  //public RabbitConfig(MyRabbitProperties myRabbitProperties) {
    //this.myRabbitProperties = myRabbitProperties;
  //}      

  @Bean 
  public TopicExchange myExchange(MyRabbitProperties myRabbitProperties) {
    return new TopicExchange(myRabbitProperties.getExchange());
  }

  @Bean
  public Queue myQueueBean(MyRabbitProperties myRabbitProperties) {
    return new Queue(myRabbitProperties.getQueue(), true);
  }

  @Bean 
  public Binding binding(Queue myQueueBean, TopicExchange myExchange, MyRabbitProperties myRabbitProperties) {
    return BindingBuilder.bind(myQueueBean).to(myExchange).with(myRabbitProperties.getRoutingKey());
  }

  @Bean
  public MyRabbitProperties myRabbitProperties() {
    return new MyRabbitProperties();
  }
}

从那里，您可以访问该字段的get方法：

@Component
public class RabbitQueueListenerClass {

  @RabbitListener(queues = "#{myRabbitProperties.getQueue()}") 
  public void processMessage(Message message) {

  }
}

Answer 3

这样的方法对我很有效，我只是用了豆子和豆子。

@Autowired
Queue queue;

@RabbitListener(queues = "#{queue.getName()}")