Захват события отключения от ActiveMQ

Question

Использование версии 1.6 NMS (1.6.3 activemq) Я настраиваю прослушиватель для ожидания сообщений. У слушателя есть нить собственной (не моя), и мой код выходит из сферы действия (пока не вызывается функция слушателя).

Если сервер ActiveMQ отключается, я получаю глобальное исключение, которое я могу использовать только глобально. (мой поток, создавший слушателя, не поймает его. Мне нечего обернуть «try» и «catch»).

Есть ли способ установить функцию обратного вызова, например - OnError + = ErrorHandlingFunction(), поскольку я использую прослушиватель для решения этой проблемы локально, а не глобальным узлом исключения? Есть ли лучший способ справиться с этой проблемой (я не могу использовать Transport Failure, поскольку у меня нет других параметров, но подождите некоторое время и отключите, возможно, зарегистрируйте что-нибудь или отправьте сообщение о том, что сервер отключен).

Answer 1

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

Методы NMS API, которые вы используете в обратном вызове async, будут генерировать исключение, если оно не подключено, поэтому, если вы сделали что-то вроде попытки ACK-сообщения в обработчике событий асинхронного сообщения, тогда оно выкинет исключение, если соединение было отключено.