Количество посетителей в ожидании от очереди + ActiveMQ + Java

Question

Мне нужно разработать Утилиту на Java, которая будет использовать API ActiveMQ, чтобы получить свойства очереди/темы, чтобы получить No of Consumers/No of Pending Messages, а также есть ли способ удалить любой Message thru Code из очереди?

Answer 1

Я бы рекомендовал использовать Statistics Plugin, чтобы получить количество потребителей, до подсчета и т.д.

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

Answer 2

Все приведенные ниже подробности относительно Queue API из ActiveMQ, вы можете найти подобные вещи для темы, а

• Нет отложенные сообщения можно найти с помощью getMessages().size()
• Нет потребитель может быть найдено getConSumers().size()
• да, можно удалять сообщения на очереди из Java кода, но нам нужно MessageReference или messageId или подходящего message Selector для того чтобы это произошло, вы можете посмотреть на официальном документация removeMessage(...) и removeMatchingMessages(...)here

надеюсь, что это помогает!

Удачи вам!