Реализация ExceptionListener на MessageListener

Question

Наша структура выглядит следующим образом: BaseQueue -> Сообщение копируется в очереди копирования (Здесь мы читаем)

Подключение к Queuemanager/Queue осуществляется через wmq.jmsra. rar.

Так что я просто хочу читать сообщения из очереди. Я не хочу отправлять ответ.

Поэтому я внедрил MessageListener и настроил очередь через файл ejb-jar.xml.

Это все работает нормально, но теперь я хочу, чтобы реализовать ExceptionListener обрабатывать потери соединения и т.д.

Я думал, что это было бы хорошо, чтобы просто реализовать интерфейс ExceptionListener так:

public class MdB implements MessageListener, ExceptionListener { 
    @Override 
    public void onMessage(Message arg0) { 
     ... 
    } 

    @Override 
    public void onException(JMSException arg0) { 
     ... 
    } 
} 

Но, похоже, этого недостаточно, поскольку метод onException никогда не вызывается из ресурсного адаптера.

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

Благодаря

Answer 1

Кроме того, необходимо зарегистрировать прослушиватель исключение с подключением по телефону setExceptionListener объекта подключения.

connection.setExceptionListener(this); // class implementing the ExceptionListener interface 

Дополнительная литература

• JMS ExceptionListener in WebSphere MQ