Как настроить эксклюзивного потребителя ActiveMQ с загрузочным приложением Spring - PullRequest
0 голосов
/ 03 декабря 2018

Я хотел настроить эксклюзивного потребителя для ActiveMQ с загрузкой Spring. Настройка с использованием Java проста

 queue = new ActiveMQQueue("TEST.QUEUE?consumer.exclusive=true");
 consumer = session.createConsumer(queue);

Но с загрузкой Spring, слушатель настраивается, как показано ниже.

 @JmsListener(destination = "TEST.QUEUE", containerFactory = "myFactory")
 public void receiveMessage(Object message) throws Exception {
    ......
 }

Теперь,как сделать этого эксклюзивного потребителя?Работает ли нижеприведенное?

 @JmsListener(destination = "TEST.QUEUE?consumer.exclusive=true", containerFactory = "myFactory")
 public void receiveMessage(Object message) throws Exception {
    ......
 }
...