Динамически создавать RabbitListner в Java RabbitMQ

Question

у меня есть дело: У меня есть класс и метод внутри него, который будет вызываться во время выполнения с такими параметрами (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();