在 Java RabbitMQ 中动态创建 Rabbit Listener

Question

我有一个案例： 我有一个 class 和里面的方法，将在运行时使用此类参数（String exchangeName、String routingKey、String queueName）调用。是否可以使用此参数创建侦听器，等待消息/或超时，然后终止侦听器。我发现的只是关于创建侦听器的注释。感谢帮助。

Answer 1

是的，有一种动态创建侦听器的方法：

SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
container.setConnectionFactory(connectionFactory);
container.setQueueNames("queueName");
container.setMessageConverter(jsonMessageConverter());
container.setMessageListener(new Consumer(container));
container.start();