Обнаружение, когда асинхронный JMS MessageConsumer имеет исключение?

Question

Я обрабатываю сообщения, используя JMS MessageConsumer с MessageListener. Если что-то происходит, это приводит к тому, что MessageConsumer перестает получать и обрабатывать сообщения - например, если базовое соединение закрывается - как я могу его обнаружить? Кажется, нет никакого механизма уведомления, который я могу найти в the spec.

Я думаю, что вопрос ясен, как есть, но если вы хотите, чтобы я опубликовал код, чтобы прояснить вопрос, просто спросите!

В случае, если это важно, я использую ActiveMQ 5.8, хотя, очевидно, мне нужна схема, которая не зависит от реализации.

Answer 1

Использование ExceptionListener

Если система JMS обнаруживает проблему, он вызывает метод onException слушателя:

public class MyConsumer implements ExceptionListener, MessageListener { 

    private void init(){ 
     Connection connection = ... //create connection 
     connection.setExceptionListener(this); 
     connection.start(); 
    } 

    public void onException(JMSException e){ 
     String errorCode = e.getErrorCode(); 
     Exception ex = e.getLinkedException(); 
     //clean up resources, or, attempt to reconnect 
    } 

    public void onMessage(Message m){ 
     ... 
} 

Не так много к нему, действительно, выше является стандартной практикой для автономных потребителей; это не зависит от реализации; фактически, наоборот, поскольку это часть спецификации !, так что все JMS-совместимые провайдеры будут поддерживать ее.