ActiveMQ Artemis поддерживает консультативные адреса и сообщения в стиле ActiveMQ 5.x. Однако, поскольку вы используете основной протокол, он вам не поможет, потому что он доступен только для клиентов OpenWire.
Возможно, вы захотите использовать уведомления управления . Если это так, то вам следует обратить особое внимание на уведомления, чей заголовок _AMQ_NotifType равен 2 (т.е. пользователь создан) и 3 (то есть потребитель закрыт). Оба эти сообщения имеют заголовок с именем _AMQ_RoutingName, который указывает, куда направляются сообщения (т. Е. Адрес, если вы используете JMS topi c, или очередь, если вы используете очередь JMS) и _AMQ_ConsumerCount, который указать, сколько там существует потребителей. Вы можете использовать эти уведомления для отслеживания потребителей, а затем запускать процессы синхронизации для принятия мер по истечении определенных порогов (например, 10 минут без потребителей).
Вы также можете использовать плагин metrics , а затем что-то вроде Prometheus (с помощью плагина Prometheus ) для управления такими предупреждениями.