Я хотел настроить эксклюзивного потребителя для 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 {
......
}