问题描述
我在Kubernetes集群中有一个服务和RabbitMQ。我想做的是,我希望服务的不同实例(或副本)在启动时声明一个全新的队列。这些队列将绑定到同一交换机。
我能以某种方式在此处放置最终变量:
public static final String QUEUE_NAME = "queue-" + UUID.randomUUID().toString();
// ...
@RabbitListener(queues = QUEUE_NAME)
本质上,我只需要一种使用生成的名称创建队列,然后使用@RabbitListener监听此队列的方法。
解决方法
好,我知道了。 我尝试解决这里的问题RabbitListener annotation queue name by ConfigurationProperties,尽管直到我用@Component(而不是@Configuration)注释Rabbit配置类并在该配置类上设置@DependsOn,它才起作用。