在 Java RabbitMQ 中动态创建 Rabbit Listener

Question

我有一个案例： 我里面有一个类和一个方法，它将在运行时使用这样的参数（字符串交换名称、字符串路由键、字符串队列名称）调用。是否可以使用此参数创建侦听器，等待消息/或超时，然后杀死侦听器。我发现的只是关于创建侦听器的注释。感谢帮助。

Answer 1

是的，有一种方法可以动态创建监听器：

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