java - 如何在 Spring Boot 中设置 amqp RabbitMQ 消费者标签？

Question

有问题How to set the consumer-tag value in spring-amqp有人问如何在使用 Spring Amqp 时更改消费者标签，答案建议提供 ConsumerTagStrategy 的实现。 .

我正在使用 Spring Boot 2.0.5，我正在尝试弄清楚我是否可以进行相同的自定义，尽管我找不到任何关于它的配置属性，也没有提供类型为 ConsumerTagStrategy 的 bean。似乎有效。

我该怎么办？

Answer 1

覆盖引导的容器工厂 bean 声明并将其添加到那里。

@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(
        SimpleRabbitListenerContainerFactoryConfigurer configurer,
        ConnectionFactory connectionFactory) {
    SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
    configurer.configure(factory, connectionFactory);
    factory.setConsumerTagStrategy(q -> "myConsumerFor." + q);
    return factory;
}