Регистрация одного прослушивателя для нескольких очередей. Является ли это возможным?
Я пишу модуль, где я собираюсь получать данные из нескольких очередей. Мне не нужно читать сообщение... но просто перенаправьте их куда-нибудь еще. Мой код выглядит примерно так.
public Class MyQueueListener implement MessageListener {
protected List<IMQDetails> mqDetailsList;
public void onMessage(Message msg) {
doSomething();
}
public void init() {
for(int i=0 ; i < mqDetailsList.size() ; i++){
QueueSession session = mqDetailsList.get(i).createSession();
QueueReceiver receiver = session.createReceiver(mqDetailsList.get(i).getQueue());
receiver.setMessageListener(this);
}
}
Мой список подробностей MQ - это интерфейс. Реализующий класс с созданием сеанса для меня.
Сложная часть (я чувствую) состоит в том, что в цикле for я создаю объект QueueRecieve и регистрирую экземпляр объекта (то есть слушателя) для него.
Например: если я подключусь к 10 различным очередям, будет ли мой OnMessage срабатывать для всех из них, независимо от того, поступило ли сообщение в какую-либо очередь?
Пожалуйста, обратите внимание: у нас нет очереди, чтобы проверить ее, и мы не можем загрузить ActiveMQ и т. Д., Чтобы смоделировать очереди.
Спасибо