Регистрация одного прослушивателя для нескольких очередей. Является ли это возможным?

Я пишу модуль, где я собираюсь получать данные из нескольких очередей. Мне не нужно читать сообщение... но просто перенаправьте их куда-нибудь еще. Мой код выглядит примерно так.

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 и т. Д., Чтобы смоделировать очереди.

Спасибо

0 ответов

Другие вопросы по тегам