代码之家 › 专栏 › 技术社区 › watery

如何在Spring Boot中设置amqp RabbitMQ consumer标签?

spring-amqp spring-boot spring java

watery · 技术社区 · 7 年前

How to set the consumer-tag value in spring-amqp 当使用springamqp时,有人询问如何更改consumer标签,答案建议提供 ConsumerTagStrategy .

我使用的是springboot2.0.5,我试图弄清楚是否可以进行同样的定制,尽管我找不到任何关于这个的配置属性,也没有提供类型为的bean 消费者战略 似乎有用。

1 回复 | 直到 7 年前

Gary Russell 7 年前

重写boot的容器工厂bean声明并将其添加到那里。

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